GearmanClient
在线手册:中文  英文

GearmanClient::addTask

(PECL gearman >= 0.5.0)

GearmanClient::addTaskAdd a task to be run in parallel

说明

public GearmanTask GearmanClient::addTask ( string $function_name , string $workload [, mixed &$context [, string $unique ]] )

Adds a task to be run in parallel with other tasks. Call this method for all the tasks to be run in parallel, then call GearmanClient::runTasks() to perform the work. Note that enough workers need to be available for the tasks to all run in parallel.

参数

function_name

由程序自动执行的已注册函数。

workload

被处理的序列化数据。

context

与任务关联的应用程序上下文。

unique

用于标识特定任务的唯一性 ID。

返回值

A GearmanTask object or FALSE if the task could not be added.

范例

Example #1 Basic submission of two tasks

<?php

# Create our gearman client
$gmclient= new GearmanClient(); 

# add the default job server
$gmclient->addServer(); 

# set a function to be called when the work is complete
$gmclient->setCompleteCallback("complete"); 

# add a task to perform the "reverse" function on the string "Hello World!"
$gmclient->addTask("reverse""Hello World!"null"1"); 

# add another task to perform the "reverse" function on the string "!dlroW olleH"
$gmclient->addTask("reverse""!dlroW olleH"null"2"); 

# run the tasks
$gmclient->runTasks(); 

function 
complete($task

  print 
"COMPLETE: " $task->unique() . ", " $task->data() . "\n"
}

?>

以上例程的输出类似于:

COMPLETE: 2, Hello World!
COMPLETE: 1, !dlroW olleH

Example #2 Basic submission of two tasks with passing application context

<?php

$client 
= new GearmanClient();
$client->addServer();

# set a function to be called when the work is complete
$client->setCompleteCallback("reverse_complete");

# Add some tasks for a placeholder of where to put the results
$results = array();
$client->addTask("reverse""Hello World!", &$results"t1");
$client->addTask("reverse""!dlroW olleH", &$results"t2");

$client->runTasks();

# The results should now be filled in from the callbacks
foreach ($results as $id => $result)
   echo 
$id ": " $result['handle'] . ", " $result['data'] . "\n";


function 
reverse_complete($task$results)
{
   
$results[$task->unique()] = array("handle"=>$task->jobHandle(), "data"=>$task->data());
}

?>

以上例程的输出类似于:

t2: H.foo:21, Hello World!
t1: H:foo:22, !dlroW olleH

参见


GearmanClient
在线手册:中文  英文

用户评论:

sfinktah at php dot spamtrak dot org (2011-04-05 18:04:49)

To create a matching worker, capable of executing multiple jobs simultaneously, I came up with this.   It's a slight hack, but it works.

<?php
do {
   
$pid false;
   
   
$gmw= new GearmanWorker();
   
$gmw->addServer("");
   
$gmw->addFunction("lookup7""lookup7_fast"$args);
   @
$gmw->work();
} while (
$pid);

function 
lookup7_fast($job) {
   global 
$pid;
   
   if (
$pid pcntl_fork()) {
      return 
$job->setReturn(GEARMAN_WORK_STATUS);
   }
    
   return 
do_work($job->workload());
};
?>

易百教程