|
@@ -25,12 +25,12 @@ class RefillSender
|
|
|
$pThis = $this;
|
|
|
$time = time() * 1000;
|
|
|
|
|
|
- for ($i = 0;$i < self::co_orders; )
|
|
|
+ for ($i = 0;$i < self::co_orders;)
|
|
|
{
|
|
|
$res = Swoole\Coroutine::stats();
|
|
|
$num = $res['coroutine_num'];
|
|
|
|
|
|
- if($num > 500) {
|
|
|
+ if($num > 1000) {
|
|
|
sleep(1);
|
|
|
continue;
|
|
|
}
|
|
@@ -64,7 +64,7 @@ class RefillSender
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-$process_count = 8;
|
|
|
+$process_count = 2;
|
|
|
|
|
|
$workers = [];
|
|
|
for ($i = 0; $i < $process_count;$i++)
|