1<?php
2
3require_once 'Net/Gearman/Client.php';
4
5$set = new Net_Gearman_Set();
6
7function result($func, $handle, $result) {
8    var_dump($func);
9    var_dump($handle);
10    var_dump($result);
11}
12
13$sql = array(
14    "SELECT * FROM users WHERE username = 'joestump'",
15    "SELECT * FROM users WHERE username LIKE 'joe%' LIMIT 10",
16    "SELECT * FROM items WHERE deleted = 0 LIMIT 10"
17);
18
19foreach ($sql as $s) {
20    $task = new Net_Gearman_Task('SQL', array(
21        'sql' => $s
22    ));
23
24    $task->attachCallback('result');
25    $set->addTask($task);
26}
27
28$client = new Net_Gearman_Client(array('dev01'));
29$client->runSet($set);
30
31?>
32