Hello, I need to create a system where records are generated by a "producer" process and processed by several "worker" processes.
I was thinking about something like: Producer: 1) Producer INSERTs new records with "state" = "new" & "worker" = "null" 2) Producer sleeps and loops back to step #1 Worker(s): 1) Worker UPDATEs all records with "worker" = "pid" & "state" = "working" where "state" == "new" 2) Worker SELECTs all records where "worker" = "pid" & "state" = "working" 3) For each record that is done, worker updates record with "state" = "done" 4) Worker loops back to step #1 Note: In this scheme the worker winds up with all "new" records generated since the last worker claimed any. Not sure how else to guarantee atomicity. I would prefer "only n records per request". Ideas? I am sure something like this must have been before.... Can anyone point me to example code, libraries, and/or refinements on the scheme? (preferably using python...) Thank you, :) -- MySQL General Mailing List For list archives: http://lists.mysql.com/mysql To unsubscribe: http://lists.mysql.com/mysql?unsub=arch...@jab.org