GearmanClient::addTask
(PECL gearman >= 0.5.0)
GearmanClient::addTask — Add a task to be run in parallel
説明
public GearmanClient::addTask
( string $function_name
, string $workload
[, mixed &$context
[, string $unique
]] ) : GearmanTask
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。
例
例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
例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 callbacksforeach ($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::addTaskHigh() - Add a high priority task to run in parallel
- GearmanClient::addTaskLow() - Add a low priority task to run in parallel
- GearmanClient::addTaskBackground() - Add a background task to be run in parallel
- GearmanClient::addTaskHighBackground() - Add a high priority background task to be run in parallel
- GearmanClient::addTaskLowBackground() - Add a low priority background task to be run in parallel
- GearmanClient::runTasks() - Run a list of tasks in parallel