发表新帖

多协程之间共用php对象变量

### 问题描述
需求：
1，并行处理列表数据
2，列表中每条数据有多个不同规则进行判断处理

如下代码中的processList,process函数在多个协程之间使用同一个php对象变量是否会有问题。

### Swoole版本，PHP版本，以及操作系统版本信息
swoole 4.5.7
php7.2
centos 7
easyswoole 3.3.7

### 相关代码
```php
<?php

class ProcLogic
{
    use Singleton;

private $rules = [
        ['method' => 'rule1', 'name' => 'rule1'], // 规则1
        ['method' => 'rule2', 'name' => 'rule2'], // 规则2
        ['method' => 'rule3', 'name' => 'rule3'], // 规则3
    ];

// 列表处理
    public function processList($list = [])
    {
        if (empty($list) || !is_array($list)) {
            return [];
        }

$wg     = new \Swoole\Coroutine\WaitGroup(count($list));
        $curObj = $this;
        $result = [];

foreach ($list as $item) {
            $wg->add();
            \Swoole\Coroutine::create(function() use($wg, $curObj, $item, &$result) {
                $result[$item['id']] = call_user_func_array([$curObj, 'process'], [$item]);
                $wg->done();
            });
        }

$wg->wait();
        foreach ($list as $key => $value) {
            $id                        = $value['id'];
            $list[$key]['rule_result'] = $result[$id][$id] ?? [];
        }

return $list;
    }

// 单条多规则处理
    public function process($item = [])
    {
        $wg     = new \Swoole\Coroutine\WaitGroup(count($this->rules));
        $curObj = $this;
        $result = [];

foreach ($this->rules as $value) {
            $method = $value['method'];
            $name   = $value['name'];
            $wg->add();
            \Swoole\Coroutine::create(function() use($wg, $curObj, $method, $item, $name, &$result) {
                $result[$item['id']][$name] = call_user_func_array([$curObj, $method], [$item]);
                $wg->done();
            });
        }

$wg->wait();

return $result;
    }

// rule1
    public function rule1($data = [])
    {
        $return = [];

// db查询 (多协程环境连接共用已处理好)
        // ...

// 返回结果
        return $return;
    }

// rule2
    public function rule2($data)
    {
        $status  = $data['use_status'];
        $return = [
            'use_status'     => $status,
            'use_status_txt' => $status == 1 ? 'ok' : '不可拆分',
        ];

return $return;
    }

// rule3
    public function rule3($data)
    {
        $return = [];

// redis查询 (多协程环境连接共用已处理好)
        // ...

// 返回结果
        return $return;
    }

}

// 调取
$list = [
    ['id' => 1, 'xx' => 'xx', 'yy' => 'yy'],
    ['id' => 2, 'xx' => 'xx', 'yy' => 'yy'],
];
$return = ProcLogic::getInstance()->processList($list);
var_dump($return);
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
目前自测运行正常
请教在多协程之间使用同一个php对象($this)会不会有什么问题？

发布于3年前 · 54 次浏览 · 来自讨论

index.php

### 问题描述
需求：
1，并行处理列表数据
2，列表中每条数据有多个不同规则进行判断处理

如下代码中的processList,process函数在多个协程之间使用同一个php对象变量是否会有问题。

### Swoole版本，PHP版本，以及操作系统版本信息
swoole 4.5.7
php7.2
centos 7
easyswoole 3.3.7

### 相关代码
```php
<?php

class ProcLogic
{
    use Singleton;

// 列表处理
    public function processList($list = [])
    {
        if (empty($list) || !is_array($list)) {
            return [];
        }

$wg     = new \Swoole\Coroutine\WaitGroup(count($list));
        $curObj = $this;
        $result = [];

$wg->wait();
        foreach ($list as $key => $value) {
            $id                        = $value['id'];
            $list[$key]['rule_result'] = $result[$id][$id] ?? [];
        }

return $list;
    }

// 单条多规则处理
    public function process($item = [])
    {
        $wg     = new \Swoole\Coroutine\WaitGroup(count($this->rules));
        $curObj = $this;
        $result = [];

$wg->wait();

return $result;
    }

// rule1
    public function rule1($data = [])
    {
        $return = [];

// db查询 (多协程环境连接共用已处理好)
        // ...

// 返回结果
        return $return;
    }

return $return;
    }

// rule3
    public function rule3($data)
    {
        $return = [];

// redis查询 (多协程环境连接共用已处理好)
        // ...

// 返回结果
        return $return;
    }

}

// 调取
$list = [
    ['id' => 1, 'xx' => 'xx', 'yy' => 'yy'],
    ['id' => 2, 'xx' => 'xx', 'yy' => 'yy'],
];
$return = ProcLogic::getInstance()->processList($list);
var_dump($return);
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
目前自测运行正常
请教在多协程之间使用同一个php对象($this)会不会有什么问题？