@@ 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 |