mirror_php/parallel
1
0
Fork 0
mirror of https://github.com/amphp/parallel.git synced 2025-02-21 13:22:44 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Faster freeing of task memory

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-11-10 10:32:01 -06:00
parent aaee76e3da
commit 0e71b18197
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/Worker/TaskRunner.php
View File

@ -37,11 +37,7 @@ class TaskRunner {
$job = yield $this->channel->receive(); $job = yield $this->channel->receive();
while ($job instanceof Internal\Job) { while ($job instanceof Internal\Job) {
$task = $job->getTask(); call([$job->getTask(), 'run'], $this->environment)->onResolve(function ($exception, $value) use ($job) {
$result = call([$task, 'run'], $this->environment);
$result->onResolve(function ($exception, $value) use ($job) {
if ($exception) { if ($exception) {
$result = new Internal\TaskFailure($job->getId(), $exception); $result = new Internal\TaskFailure($job->getId(), $exception);
} else { } else {
@ -51,6 +47,8 @@ class TaskRunner {
$this->channel->send($result); $this->channel->send($result);
}); });
unset($job); // Free memory from last job.
$job = yield $this->channel->receive(); $job = yield $this->channel->receive();
} }