修复投递任务每次都在同一个task进程问题

imiphp · Jun 21, 2018 · 3748ffd · 3748ffd
1 parent 3bad566
commit 3748ffd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Task/TaskManager.php b/src/Task/TaskManager.php
@@ -15,7 +15,7 @@ abstract class TaskManager
 	 * @param int $workerID
 	 * @return int|bool
 	 */
-	public static function post(TaskInfo $taskInfo, $workerID = null)
+	public static function post(TaskInfo $taskInfo, $workerID = -1)
 	{
 		return ServerManage::getServer('main')->getSwooleServer()->task($taskInfo, $workerID, [$taskInfo->getTaskHandler(), 'finish']);
 	}
@@ -28,7 +28,7 @@ public static function post(TaskInfo $taskInfo, $workerID = null)
 	 * @param int $workerID
 	 * @return string|bool
 	 */
-	public static function postWait(TaskInfo $taskInfo, $timeout, $workerID = null)
+	public static function postWait(TaskInfo $taskInfo, $timeout, $workerID = -1)
 	{
 		$server = ServerManage::getServer('main')->getSwooleServer();
 		$result = $server->taskwait($taskInfo, $timeout, $workerID);