Skip to content

Commit 47103e2

Browse files
committed
修复消费进程只能同时消费一个的问题
1 parent 331bea9 commit 47103e2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Service/BaseQueueConsumer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public function run(ITaskParam $param)
118118
$pool->run();
119119
for($i = 0; $i < $co; ++$i)
120120
{
121-
$pool->addTask([
121+
$pool->addTaskAsync([
122122
'task' => $task,
123123
]);
124124
}

0 commit comments

Comments
 (0)