Kolejka w PHP, Opcje

[Prph]

Dawno mnie tu nie było (IMG:style_emoticons/default/smile.gif)

Forumowicze, problem z kolejką w PHP. System, który tworzę przetwarza dane co minutę (z CRONa). Niestety uruchomienie pojedynczego procesu np, przetwarzaj.php nie kończy się w 1 minucie, ponieważ przetwarzanie danych może trwać np. 2 mninuty dla pojedynczego rekordu bazy danych, a rekordów jest np. 20. Teoretycznie szeregowe uruchomienie przetwarzania zajmie więc 40 min. Każdy przetwarzaj.pho bierze z bazy zatem 1 rekord i tylko taki mieli.

Moje pytanie: w jaki sposób napisać kolejkę, która poprawnie przetworzy takie dane? Wywołać z crona 20x ten sam przetwarzaj.php? Zanim proces zacznie wykonywać swoją pracę, ustawia na rekordzie bazy, że jest on przetwarzany, więc inny proces weźmie kolejne dane.

Spotkaliście się z podobnym problemem, macie pomysły?

[Prph]

Zrobione za pomocą forkowania. Aż miło patrzeć jak to działa (IMG:style_emoticons/default/smile.gif)

[PHP] pobierz, plaintext 
 
	$sql ='tutaj selekt pobierający listę do wysłania...';
 
	$res = db_query($sql);
	$queue = db_fetch_all($res);
 
	if(!count($queue)) {
		echo "Nothing to send\n";
	}
 
	$numOfPids = 0;
	$processes = array();
	foreach($queue as $entry) {
 
		$processes[$numOfPids] = pcntl_fork();
		if($processes[$numOfPids]) { // this is parent process
			$numOfPids++;
		}
		else {
 
			echo "In $numOfPids process, sending {$entry['id']}\n";
 
			// ok we are in the child
			// send data
 
			// have to connect again
			db_connect('...');
 
			$update = array('status' => 'in_process');
			db_update('...'));
			send_data($entry); // funkcja wysyłająca
 
			echo "Process $numOfPids sent data\n";
 
			exit();
		}
	}
[PHP] pobierz, plaintext 

Wynik:

[PHP] pobierz, plaintext 
In 0 process, sending 5790
In 1 process, sending 5791
In 2 process, sending 5797
Process 0 sent data
Process 2 sent data
Process 1 sent data
It's done!
[PHP] pobierz, plaintext