as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-12 12:57:32 +08:00
parent 3f4a44e9fd
commit 3d09da1688
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+5 -2
View File
@@ -66,10 +66,13 @@ class Kafka extends \Snowflake\Process\Process
*/ */
public function channelListener($config) public function channelListener($config)
{ {
$this->channel = new Channel($config['size'] ?? 100); if (!isset($config['size'])) {
$config['size'] = 100;
}
$this->channel = new Channel($config['size']);
Coroutine::create(function () use ($config) { Coroutine::create(function () use ($config) {
$group = new WaitGroup(); $group = new WaitGroup();
for ($i = 0; $i < $config['size'] ?? 100; $i++) { for ($i = 0; $i < $config['size']; $i++) {
$group->add(); $group->add();
go(function () use ($group) { go(function () use ($group) {
defer(function () use ($group) { defer(function () use ($group) {