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

相关文章
tomcat中context导致定时任务等程序执行两次php pthreads pool 类php 杂项 函数 中断编译器的执行php 别名和过时的 mysqli 函数 在主/从机制中强制在主机中执行一个查询php mysqlnd ms 函数 查询给定的 sql 会发送给 master、slave 还是最后使用的 mysql server 执行。php oci8 函数 提交未执行的事务处理php pcre 函数 执行一个正则表达式搜索并且使用一个回调进行替换php pcre 函数 执行一个正则表达式的搜索和替换php pool 回收已完成任务的引用php pool 创建新的 worker 对象池php pool 改变 pool 对象的可容纳 worker 对象的数量php pool 停止所有的 worker 对象php pool 提交对象以执行php pool 提交一个任务到特定的 worker 以执行php varnishadmin start varnish worker processphp varnishadmin stop varnish worker processphp worker collect references to completed tasksphp worker 获取剩余的栈大小php worker 将要执行的任务入栈php worker 将要执行的任务出栈
关注编程学问公众号