Threaded::chunk()函数—用法及示例

函数名：Threaded::chunk()

适用版本：PHP 7.2.0+

用法：Threaded::chunk() 函数将一个线程对象按照指定大小分块，并返回一个包含这些块的数组。

语法：

public Threaded::chunk(int $size, bool $preserve = false): array

参数：

• $size：每个块的大小。
• $preserve（可选）：如果为 true，则保留原始数组的键。默认为 false。

返回值： 返回一个包含分块后的数组的新数组。

示例：

class MyThread extends Thread {
    public $data;

    public function __construct($data) {
        $this->data = $data;
    }

    public function run() {
        // 在这里执行线程的任务
    }
}

$threads = [];
$data = range(1, 10);

// 创建线程对象
foreach (Threaded::chunk($data, 3) as $chunk) {
    $thread = new MyThread($chunk);
    $thread->start();
    $threads[] = $thread;
}

// 等待所有线程完成
foreach ($threads as $thread) {
    $thread->join();
}

在上面的示例中，我们首先将原始数据数组 $data 使用 Threaded::chunk() 函数分成了大小为3的块。然后，我们创建了一个 MyThread 类的实例，将每个块作为构造函数的参数传递给线程对象。接下来，我们使用 start() 方法启动每个线程，并将线程对象存储在 $threads 数组中。最后，我们使用 join() 方法等待所有线程完成任务。

请注意，Threaded::chunk() 函数只在 PHP 7.2.0 或更高版本中可用。