Exclude mutations that are over specified time limit

src/Container.php

@@ -447,7 +447,8 @@ public static function create(): self
                     $container->getParallelProcessRunner(),
                     $container->getEventDispatcher(),
                     $container->getFileSystem(),
-                    $container->getConfiguration()->noProgress()
+                    $container->getConfiguration()->noProgress(),
+                    $container->getConfiguration()->getProcessTimeout()
                 );
             },
             LineRangeCalculator::class => static function (): LineRangeCalculator {

src/Mutant/MutantExecutionResult.php

@@ -77,17 +77,12 @@ public function __construct(
 
     public static function createFromNonCoveredMutant(Mutant $mutant): self
     {
-        $mutation = $mutant->getMutation();
+        return self::createFromMutant($mutant, DetectionStatus::NOT_COVERED);
+    }
 
-        return new self(
-            '',
-            '',
-            DetectionStatus::NOT_COVERED,
-            $mutant->getDiff(),
-            $mutant->getMutation()->getMutatorName(),
-            $mutation->getOriginalFilePath(),
-            $mutation->getOriginalStartingLine()
-        );
+    public static function createFromTimeConstrainedMutant(Mutant $mutant): self
+    {
+        return self::createFromMutant($mutant, DetectionStatus::TIMED_OUT);
     }
 
     public static function createFromProcess(MutantProcess $mutantProcess): self
@@ -141,4 +136,19 @@ public function getOriginalStartingLine(): int
     {
         return $this->originalStartingLine;
     }
+
+    private static function createFromMutant(Mutant $mutant, string $detectionStatus): self
+    {
+        $mutation = $mutant->getMutation();
+
+        return new self(
+            '',
+            '',
+            $detectionStatus,
+            $mutant->getDiff(),
+            $mutant->getMutation()->getMutatorName(),
+            $mutation->getOriginalFilePath(),
+            $mutation->getOriginalStartingLine()
+        );
+    }
 }

src/Mutation/Mutation.php

@@ -37,6 +37,8 @@
 
 use function array_intersect_key;
 use function array_keys;
+use function array_map;
+use function array_sum;
 use function count;
 use function implode;
 use Infection\AbstractTestFramework\Coverage\TestLocation;
@@ -164,6 +166,18 @@ public function getAllTests(): array
         return $this->tests;
     }
 
+    /**
+     * Overall time needed to run known tests for a mutation, excluding dependencies.
+     */
+    public function getTimeToTest(): float
+    {
+        // TODO this needs to be memoized
+
+        return array_sum(array_map(static function (TestLocation $data) {
+            return $data->getExecutionTime();
+        }, $this->tests));
+    }
+
     public function getHash(): string
     {
         return $this->hash ?? $this->hash = $this->createHash();

src/Process/Builder/MutantProcessBuilder.php

@@ -53,7 +53,7 @@ class MutantProcessBuilder
     public function __construct(TestFrameworkAdapter $testFrameworkAdapter, int $timeout)
     {
         $this->testFrameworkAdapter = $testFrameworkAdapter;
-        $this->timeout = $timeout;
+        $this->timeout = (float) $timeout;
     }
 
     public function createProcessForMutant(Mutant $mutant, string $testFrameworkExtraOptions = ''): MutantProcess
@@ -68,7 +68,7 @@ public function createProcessForMutant(Mutant $mutant, string $testFrameworkExtr
             )
         );
 
-        $process->setTimeout((float) $this->timeout);
+        $process->setTimeout($this->timeout);
 
         if (method_exists($process, 'inheritEnvironmentVariables')) {
             // in version 4.4.0 this method is deprecated and removed in 5.0.0

src/Process/Runner/MutationTestingRunner.php

@@ -61,21 +61,24 @@ final class MutationTestingRunner
     private $eventDispatcher;
     private $fileSystem;
     private $runConcurrently;
+    private $timeout;
 
     public function __construct(
         MutantProcessBuilder $mutantProcessBuilder,
         MutantFactory $mutantFactory,
         ParallelProcessRunner $parallelProcessManager,
         EventDispatcher $eventDispatcher,
         Filesystem $fileSystem,
-        bool $runConcurrently
+        bool $runConcurrently,
+        int $timeout
     ) {
         $this->processBuilder = $mutantProcessBuilder;
         $this->mutantFactory = $mutantFactory;
         $this->parallelProcessManager = $parallelProcessManager;
         $this->eventDispatcher = $eventDispatcher;
         $this->fileSystem = $fileSystem;
         $this->runConcurrently = $runConcurrently;
+        $this->timeout = $timeout;
     }
 
     /**
@@ -101,6 +104,17 @@ public function run(iterable $mutations, int $threadCount, string $testFramework
 
                 return false;
             })
+            ->filter(function (Mutant $mutant) {
+                if ($mutant->getMutation()->getTimeToTest() < $this->timeout) {
+                    return true;
+                }
+
+                $this->eventDispatcher->dispatch(new MutantProcessWasFinished(
+                    MutantExecutionResult::createFromTimeConstrainedMutant($mutant)
+                ));
+
+                return false;
+            })
             ->map(function (Mutant $mutant) use ($testFrameworkExtraOptions): MutantProcess {
                 $this->fileSystem->dumpFile($mutant->getFilePath(), $mutant->getMutatedCode());