时间戳

首页 > 解决方案 > 如何在 amphp/parallel Amp\Loop 中调用 worker CallableTask 中的类方法？

php - 如何在 amphp/parallel Amp\Loop 中调用 worker CallableTask 中的类方法？

问题描述

我正在使用 Amp\Loop 并想知道使用 $worker->enqueue(new CallableTask()) 中的参数调用类方法的正确方法是什么。
这是一个例子：

<?php
require_once "vendor/autoload.php";
use Amp\Loop;
use Amp\Parallel\Worker\CallableTask;
use Amp\Parallel\Worker\DefaultWorkerFactory;


class Test_Amp {

  public function __construct() {
    $this->run_test();
  }
  public function run_test() {
    Amp\Loop::run(function () {
    $a = "";
    $b = "";
    $factory = new DefaultWorkerFactory();
    $worker = $factory->create();
    $result = yield $worker->enqueue(new CallableTask(array(&$this, 'run_task'), [$a, $b])); // Is it the correct way of calling run_task() ?
    $code = yield $worker->shutdown();
    });
  }

  public function run_task($a, $b) {
    //do something with $a and $b
  }
}

new Test_Amp();

标签： phpamphp

解决方案

是的，这基本上是正确的。你不需要&前面的$this。

除了使用CallableTask，您还可以实现自己的Task.

请注意，您的整个对象在发送给工作人员时被序列化并在工作人员中反序列化，因此对子对象所做的修改在父对象中不可见，反之亦然。

推荐阅读