Pool::submitTo

(PECL pthreads >= 2.0.0)

Pool::submitTo — 提交一个任务到特定的 Worker 以执行

说明

public Pool::submitTo ( int $worker , Threaded $task ) : int

将对象提交到 Pool 中某个特定的 Worker 对象来执行。Worker 的下标从 0 开始， 由于 Pool 中的线程是懒加载机制， 所以 Worker 对象仅在 Pool 需要执行任务的时候才会真正被创建。

参数

worker

用来执行任务的 Worker 对象，下标从 0 开始。

task

要执行的任务

返回值

接受新加入对象的 Worker 对象ID

范例

Example #1 提交任务到特定的 Worker

<?php
class Task extends Threaded {
    public function run() {
        var_dump(Thread::getCurrentThreadID());
    }
}

$pool = new Pool(2);

$pool->submit(new Task());

for ($i = 0; $i < 5; ++$i) {
    $pool->submitTo(0, new Task()); // 将所有的任务都入栈到下标为 0 的 Worker
}

$pool->submitTo(1, new Task()); // 由于第二个 Worker 尚未存在，所以不可以将任务入栈到第二个 Worker

$pool->shutdown();

以上例程会输出：

int(4475011072)
int(4475011072)
int(4475011072)
int(4475011072)
int(4475011072)
int(4475011072)

Fatal error: Uncaught Exception: The selected worker (1) does not exist in %s:%d

相关文章
php 过滤器函数 通过名称获取特定的外部变量，并且可以通过过滤器处理它php oci8 函数 提交未执行的事务处理php pcntl 函数 在当前进程空间执行指定程序php pcntl 函数 在当前进程当前位置产生分支（子进程）。译注：fork是创建了一个子进程，父进程和子进程 都从fork的位置开始向下继续执行，不同的是父进程执行过程中，得到的fork返回值为子进程 号，而子进程得到的是0。php gearmanworker give the worker an identifier so it can be tracked when asking gearmand for the list of available workersphp lua 将字符串当做lua代码执行php mongo get pool size for connection poolsphp mongopool get pool size for connection poolsphp pdostatement 执行一条预处理语句php pool 回收已完成任务的引用php pool 创建新的 worker 对象池php pool 改变 pool 对象的可容纳 worker 对象的数量php pool 停止所有的 worker 对象php pool 提交对象以执行php pool 提交一个任务到特定的 worker 以执行php sphinxclient 执行搜索查询php swoole server used in task process for sending result to the worker process when the task is finished.php swoole server shutdown the master server process this function can be called in worker processes.php worker 将要执行的任务入栈php worker 将要执行的任务出栈
关注编程学问公众号