发表新帖

\Swoole\Coroutine\map函数的回调参数,能否添加一个数组的key

Swoole内置封装了map函数,但是在遍历数据时,数组的key($id)并没有传入回调的参数中,有些情况下我们会对数据进行分组,分组的key是很重要的,希望能传入
原来的ide-helper里的代码:
```php
function map(array $list, callable $fn, float $timeout = -1): array
{
    $wg = new WaitGroup(count($list));
    foreach ($list as $id => $elem) {
        Coroutine::create(function () use ($wg, &$list, $id, $elem, $fn): void {
            $list[$id] = null;
            $list[$id] = $fn($elem);
            $wg->done();
        });
    }
    $wg->wait($timeout);
    return $list;
}
```
希望改进的代码:
```php
$list = [
	'IoUesAnBJV' => [1, 2, 3],
	'93JS1id16R' => [7, 2, 3],
	'0EDCtZOAx0' => [6, 2, 3],
	'hBtnq0j2U0' => [5, 2, 3],
	'u4lfDZum9m' => [4, 2, 3],
	'xcuTIaZyqq' => [3, 2, 3],
	'aVD9EP0s5H' => [6, 3, 3],
	'43T7vekEDk' => [4, 3, 2],
	'VR3dUbW29p' => [7, 8, 9],
	'aOur7ZvEgN' => [5, 2, 6]
];
function map(array $list, callable $fn, float $timeout = -1): array
{
    $wg = new WaitGroup(count($list));
    foreach ($list as $id => $elem) {
        Coroutine::create(function () use ($wg, &$list, $id, $elem, $fn): void {
            $list[$id] = null;
            $list[$id] = $fn($elem, $id);
            $wg->done();
        });
    }
    $wg->wait($timeout);
    return $list;
}
```

发布于1年前 · 23 次浏览 · 来自建议

左心房的痛

Swoole内置封装了map函数,但是在遍历数据时,数组的key($id)并没有传入回调的参数中,有些情况下我们会对数据进行分组,分组的key是很重要的,希望能传入
原来的ide-helper里的代码:
```php
function map(array $list, callable $fn, float $timeout = -1): array
{
    $wg = new WaitGroup(count($list));
    foreach ($list as $id => $elem) {
        Coroutine::create(function () use ($wg, &$list, $id, $elem, $fn): void {
            $list[$id] = null;
            $list[$id] = $fn($elem);
            $wg->done();
        });
    }
    $wg->wait($timeout);
    return $list;
}
```
希望改进的代码:
```php
$list = [
	'IoUesAnBJV' => [1, 2, 3],
	'93JS1id16R' => [7, 2, 3],
	'0EDCtZOAx0' => [6, 2, 3],
	'hBtnq0j2U0' => [5, 2, 3],
	'u4lfDZum9m' => [4, 2, 3],
	'xcuTIaZyqq' => [3, 2, 3],
	'aVD9EP0s5H' => [6, 3, 3],
	'43T7vekEDk' => [4, 3, 2],
	'VR3dUbW29p' => [7, 8, 9],
	'aOur7ZvEgN' => [5, 2, 6]
];
function map(array $list, callable $fn, float $timeout = -1): array
{
    $wg = new WaitGroup(count($list));
    foreach ($list as $id => $elem) {
        Coroutine::create(function () use ($wg, &$list, $id, $elem, $fn): void {
            $list[$id] = null;
            $list[$id] = $fn($elem, $id);
            $wg->done();
        });
    }
    $wg->wait($timeout);
    return $list;
}
```

评论

2023-04-08

Rango

2023-04-10

左心房的痛 回复 Rango

微信公众号

Swoole官方公众号

作者其它话题

- 如何唤醒sleep的协程？

- 协程使用use关键字引入外部变量禁止使用引用?

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。