代码提交
This commit is contained in:
@@ -71,8 +71,8 @@ class TaskServer extends Server
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
// 3个进程处理获客新任务
|
// 进程处理获客新任务
|
||||||
if ($current_worker_id < 3) {
|
if ($current_worker_id == 2) {
|
||||||
Timer::add(1, function () use ($current_worker_id, $process_count_for_status_0, $adapter) {
|
Timer::add(1, function () use ($current_worker_id, $process_count_for_status_0, $adapter) {
|
||||||
$adapter->handleCustomerTaskWithStatusIsNew($current_worker_id, $process_count_for_status_0);
|
$adapter->handleCustomerTaskWithStatusIsNew($current_worker_id, $process_count_for_status_0);
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user