| @@ 67-73 (lines=7) @@ | ||
| 64 | \PHPDaemon\Core\Timer::add(function ($event) use ($job) { |
|
| 65 | ||
| 66 | // Adding async job bar |
|
| 67 | $job('bar', function ($jobname, $job) { |
|
| 68 | \PHPDaemon\Core\Timer::add(function ($event) use ($jobname, $job) { |
|
| 69 | // Job done |
|
| 70 | $job->setResult($jobname, ['job' => 'bar', 'success' => false, 'line' => __LINE__]); |
|
| 71 | $event->finish(); |
|
| 72 | }, 1e3 * 50); |
|
| 73 | }); |
|
| 74 | ||
| 75 | // Adding async job baz. Equal $job('baz', $this->baz()); |
|
| 76 | $job->addJob('baz', $this->baz()); |
|
| @@ 86-94 (lines=9) @@ | ||
| 83 | }, 1e6 * 1); |
|
| 84 | } |
|
| 85 | ||
| 86 | final public function foo($arg) |
|
| 87 | { |
|
| 88 | return function ($jobname, $job) use ($arg) { |
|
| 89 | \PHPDaemon\Core\Timer::add(function ($event) use ($jobname, $job, $arg) { |
|
| 90 | // Job done |
|
| 91 | $job->setResult($jobname, ['job' => 'foo', 'success' => true, 'line' => __LINE__, 'arg' => $arg]); |
|
| 92 | $event->finish(); |
|
| 93 | }, 1e3 * 100); |
|
| 94 | }; |
|
| 95 | } |
|
| 96 | ||
| 97 | final public function baz() |
|
| @@ 97-105 (lines=9) @@ | ||
| 94 | }; |
|
| 95 | } |
|
| 96 | ||
| 97 | final public function baz() |
|
| 98 | { |
|
| 99 | return function ($jobname, $job) { |
|
| 100 | \PHPDaemon\Core\Timer::add(function ($event) use ($jobname, $job) { |
|
| 101 | // Job done |
|
| 102 | $job->setResult($jobname, ['job' => 'baz', 'success' => false, 'line' => __LINE__]); |
|
| 103 | $event->finish(); |
|
| 104 | }, 1e3 * 300); |
|
| 105 | }; |
|
| 106 | } |
|
| 107 | } |
|
| 108 | ||