How return data from the Swoole\Coroutine\Scheduler?

[AkioSarkiz]

code

$scheduler = $this->createScheduler();
$this->setUpScheduler($scheduler);
$scheduler->start();

How can I return data from Scheduler? I couldn't find it in the examples.

[sy-records]

you can use Coroutine\Channel

use Swoole\Coroutine;

Coroutine\run(function () {
    $channel = new Coroutine\Channel(1);

    go(function ($a, $b) use ($channel) {
        Coroutine::sleep(1);
        echo assert($a == 'hello') . PHP_EOL;
        echo assert($b == 12345) . PHP_EOL;
        $channel->push('done');
    }, "hello", 12345);

    var_dump($channel->pop());
});

[AkioSarkiz]

Yes, that works. But if I want to return the data to the main PHP thread. Is this unreal?

[AkioSarkiz]

example

$data = [];
$scheduler = new Scheduler();
$scheduler->set(['max_coroutine' => $this->maxCountCoroutines]);
$scheduler->add(fn(string $token) => $data[] = $this->getFromFirstServer($token), $token);
$scheduler->add(fn(string $token) => $data[] = $this->getFromSecondServer($token), $token);
$scheduler->start();

var_dump($data);

[sy-records]

use Swoole\Coroutine;
use function Swoole\Coroutine\batch;

$start_time = microtime(true);
Coroutine\run(function () {
    $use = microtime(true);
    $results = batch([
        'file_put_contents' => function () {
            return file_put_contents(__DIR__ . '/greeter.txt', "Hello,Swoole.");
        },
        'gethostbyname' => function () {
            return gethostbyname('localhost');
        },
        'file_get_contents' => function () {
            return file_get_contents(__DIR__ . '/greeter.txt');
        },
        'sleep' => function () {
            sleep(1);
            return true;
        },
        'usleep' => function () {
            usleep(1000);
            return true;
        },
    ], 0.1);
    $use = microtime(true) - $use;
    echo "Use {$use}s, Result:\n";
    var_dump($results);
});

[twose]

example

$data = [];
$scheduler = new Scheduler();
$scheduler->set(['max_coroutine' => $this->maxCountCoroutines]);
$scheduler->add(fn(string $token) => $data[] = $this->getFromFirstServer($token), $token);
$scheduler->add(fn(string $token) => $data[] = $this->getFromSecondServer($token), $token);
$scheduler->start();

var_dump($data);

I think I see what you mean, but you can only get data by reference vars or global vars for the time being...

Coroutine\run(function () use (&$data) {
    $channel = new Coroutine\Channel(1);

    go(function ($a, $b) use ($channel) {
        Coroutine::sleep(1);
        echo assert($a == 'hello') . PHP_EOL;
        echo assert($b == 12345) . PHP_EOL;
        $channel->push('done');
    }, "hello", 12345);

    $data = $channel->pop();
});

var_dump($data);