@@ -45,6 +45,7 @@ discard block |
||
45 | 45 | |
46 | 46 | /** |
47 | 47 | * @param int $ownerPid |
48 | + * @param Log $log |
|
48 | 49 | */ |
49 | 50 | public function __construct($ownerPid, $log, $concurrency = 5) |
50 | 51 | { |
@@ -60,6 +61,7 @@ discard block |
||
60 | 61 | |
61 | 62 | /** |
62 | 63 | * @param \Ackintosh\Snidel\Task |
64 | + * @param Task $task |
|
63 | 65 | * @return void |
64 | 66 | */ |
65 | 67 | public function enqueue($task) |
@@ -155,6 +157,7 @@ discard block |
||
155 | 157 | * fork worker process |
156 | 158 | * |
157 | 159 | * @param \Ackintosh\Snidel\Task |
160 | + * @param Task $task |
|
158 | 161 | * @return void |
159 | 162 | * @throws \RuntimeException |
160 | 163 | */ |
@@ -262,7 +265,7 @@ discard block |
||
262 | 265 | } |
263 | 266 | |
264 | 267 | /** |
265 | - * @return array |
|
268 | + * @return integer[] |
|
266 | 269 | */ |
267 | 270 | public function getChildPids() |
268 | 271 | { |
@@ -280,6 +283,9 @@ discard block |
||
280 | 283 | return $this->forks[$pid]; |
281 | 284 | } |
282 | 285 | |
286 | + /** |
|
287 | + * @param string $tag |
|
288 | + */ |
|
283 | 289 | public function getCollection($tag = null) |
284 | 290 | { |
285 | 291 | if ($tag === null) { |
@@ -293,7 +299,7 @@ discard block |
||
293 | 299 | * return forks |
294 | 300 | * |
295 | 301 | * @param string $tag |
296 | - * @return \Ackintosh\Snidel\Fork[] |
|
302 | + * @return ForkCollection |
|
297 | 303 | */ |
298 | 304 | private function getCollectionWithTag($tag) |
299 | 305 | { |
@@ -313,7 +319,7 @@ discard block |
||
313 | 319 | } |
314 | 320 | |
315 | 321 | /** |
316 | - * @return \Ackintosh\Sniden\Error |
|
322 | + * @return Error |
|
317 | 323 | */ |
318 | 324 | public function getError() |
319 | 325 | { |
@@ -8,6 +8,7 @@ |
||
8 | 8 | { |
9 | 9 | /** |
10 | 10 | * @param \Ackintosh\Snidel\Fork |
11 | + * @param Fork $fork |
|
11 | 12 | * @throws \RuntimeException |
12 | 13 | */ |
13 | 14 | public function enqueue($fork) |
@@ -18,7 +18,6 @@ discard block |
||
18 | 18 | /** |
19 | 19 | * @param callable $callable |
20 | 20 | * @param array $args |
21 | - * @param string $string |
|
22 | 21 | */ |
23 | 22 | public function __construct($callable, $args, $tag) |
24 | 23 | { |
@@ -44,7 +43,7 @@ discard block |
||
44 | 43 | } |
45 | 44 | |
46 | 45 | /** |
47 | - * @return string|null |
|
46 | + * @return string |
|
48 | 47 | */ |
49 | 48 | public function getTag() |
50 | 49 | { |