while($row = mysql_fetch_array($result)){
	$pageid = $row['pageid'];
	$clients = count(scandir("clients/"));
	while ($clients > 20) {
		sleep(1);
		$clients = count(scandir("clients/"));
	}
	exec("wget http://domain.de/arbeiter.php?id=".$pageid." >/dev/null &", $execute);
}

while ($clients > 20) {

echo "<br>".date('Y-m-d H:i:s').": ";
$cwd = null;
$pageid = 721954;
$env = null;

$cmd = "/usr/bin/php -f example.php ".$pageid;

$process = proc_open($cmd , $descriptorspec, $pipes, $cwd, $env);
$maxcount = 0;

if (is_resource($process)) {
	$status = proc_get_status($process);
	file_put_contents("clients/log.txt",date('Y-m-d H:i:s')." Starting Process ".$status["pid"]."\n");
	$running = true;
	
	while ($running == true && $maxcount < 20) {
		$log = print_r($status, true);
		file_put_contents("clients/log.txt",date('Y-m-d H:i:s')." Status: ".$log."\n", FILE_APPEND);
		$maxcount++;
		sleep(5);
		$status = proc_get_status($process);
		if ($status === false) {
			$running = false;
		}
		// if (isset($status["running"])) {
			// $running = $status["running"];
		// } else {
			// $running = false;
		// }
	}
	
	
	
	
	echo "<br>Prozess beendet<br>";
    $return_value = proc_close($process);

	echo "<br>".date('Y-m-d H:i:s').": ";
	print_r($status);

	echo "<br>";
    echo "Rückgabewert des Kommandos: $return_value\n";
}

$status["running"] == true

// 100 Arbeiter starten :-)
$worker = array();
for ($i = 1; $i <= 100; $i++) {
	$cmd = "php -f test_worker.php >/dev/null &";
	$process = proc_open($cmd , $descriptorspec, $pipes, $cwd, $env);
	$worker[$i] = $process;
}



echo "<br>".date('Y-m-d H:i:s').": "."<br>";
echo count($worker);

// 10000 Aufgabe holen
// und diese der Reihe nach an die Arbeiter verteilen

# create our client object
$client= new GearmanClient();
# add the default server (localhost)
$client->addServer();

$jobs = array();
for ($i = 1; $i <= 1000; $i++) {

	$job = $client->doBackground("reverse", "this is test ".$i, $i);

	if ($client->returnCode() == GEARMAN_SUCCESS)
	{
		$jobs[$i] = $job;
	}
}
// Aufgaben überwachen
$running = true;
while ($running == true) {
	sleep(1);

	foreach($jobs AS $key => $value) {
		$status = $client->jobStatus( $value );

		if (!$status[0]) {
			unset($jobs[$key]);
		}
	}
	echo "<br>".date('Y-m-d H:i:s')."  ".count($jobs) ." jobs are running<br />\n";
	if (count($jobs) < 10) {
		$running = false;
	}
}

// Die Arbeiter dürfen aufhören...
foreach ($worker AS $value) {
	// proc_close($value);
	proc_terminate($value);
}