@@ -2,7 +2,6 @@ |
||
2 | 2 | namespace Ackintosh\Snidel\Task; |
3 | 3 | |
4 | 4 | use Ackintosh\Snidel\Task\TaskInterface; |
5 | -use Ackintosh\Snidel\Task\MinifiedTask; |
|
6 | 5 | |
7 | 6 | class Task implements TaskInterface |
8 | 7 | { |
@@ -19,7 +19,6 @@ discard block |
||
19 | 19 | /** |
20 | 20 | * @param callable $callable |
21 | 21 | * @param array $args |
22 | - * @param string $string |
|
23 | 22 | */ |
24 | 23 | public function __construct($callable, $args, $tag) |
25 | 24 | { |
@@ -45,7 +44,7 @@ discard block |
||
45 | 44 | } |
46 | 45 | |
47 | 46 | /** |
48 | - * @return string|null |
|
47 | + * @return string |
|
49 | 48 | */ |
50 | 49 | public function getTag() |
51 | 50 | { |
@@ -53,7 +52,7 @@ discard block |
||
53 | 52 | } |
54 | 53 | |
55 | 54 | /** |
56 | - * @return Ackintosh\Snidel\Result\Result |
|
55 | + * @return Result |
|
57 | 56 | */ |
58 | 57 | public function execute() |
59 | 58 | { |
@@ -126,7 +126,7 @@ discard block |
||
126 | 126 | * @param mixed $args |
127 | 127 | * @param string $tag |
128 | 128 | * @param \Ackintosh\Snidel\Token $token |
129 | - * @return void |
|
129 | + * @return null|integer |
|
130 | 130 | * @throws \RuntimeException |
131 | 131 | */ |
132 | 132 | private function forkChild(Token $token, $callable, $args = array(), $tag = null) |
@@ -313,6 +313,7 @@ discard block |
||
313 | 313 | * fork the first processing of the map container |
314 | 314 | * |
315 | 315 | * @param \Ackintosh\Snidel\MapContainer |
316 | + * @param Token $token |
|
316 | 317 | * @return void |
317 | 318 | * @throws \RuntimeException |
318 | 319 | */ |
@@ -54,6 +54,7 @@ discard block |
||
54 | 54 | |
55 | 55 | /** |
56 | 56 | * @param int $ownerPid |
57 | + * @param \Ackintosh\Snidel\Log $log |
|
57 | 58 | */ |
58 | 59 | public function __construct($ownerPid, $log, $concurrency = 5) |
59 | 60 | { |
@@ -69,6 +70,7 @@ discard block |
||
69 | 70 | |
70 | 71 | /** |
71 | 72 | * @param \Ackintosh\Snidel\Task |
73 | + * @param \Ackintosh\Snidel\Task\Task $task |
|
72 | 74 | * @return void |
73 | 75 | * @throws \RuntimeException |
74 | 76 | */ |
@@ -304,7 +306,7 @@ discard block |
||
304 | 306 | } |
305 | 307 | |
306 | 308 | /** |
307 | - * @return array |
|
309 | + * @return integer[] |
|
308 | 310 | */ |
309 | 311 | public function getChildPids() |
310 | 312 | { |
@@ -315,13 +317,16 @@ discard block |
||
315 | 317 | * return fork |
316 | 318 | * |
317 | 319 | * @param int $pid |
318 | - * @return \Ackintosh\Snidel\Fork\Fork |
|
320 | + * @return Result |
|
319 | 321 | */ |
320 | 322 | public function get($pid) |
321 | 323 | { |
322 | 324 | return $this->results[$pid]; |
323 | 325 | } |
324 | 326 | |
327 | + /** |
|
328 | + * @param string $tag |
|
329 | + */ |
|
325 | 330 | public function getCollection($tag = null) |
326 | 331 | { |
327 | 332 | if ($tag === null) { |
@@ -364,7 +369,7 @@ discard block |
||
364 | 369 | } |
365 | 370 | |
366 | 371 | /** |
367 | - * @return \Ackintosh\Sniden\Error |
|
372 | + * @return Error |
|
368 | 373 | */ |
369 | 374 | public function getError() |
370 | 375 | { |