iro.hg: iro/worker.py@0d7ffb9b2c7f (annotated)

0 a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	1	# -- coding: utf-8 --
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	2	# Worker code
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	3
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	4	from multiprocessing import Process
20 0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	5	import logging
0 a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	6	import time
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	7
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	8	class Worker(Process):
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	9	def __init__(self,queue):
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	10	Process.__init__(self)
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	11	self.queue=queue
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	12
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	13	def run(self):
20 0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	14	logging.info('Worker thread läuft nun...')
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	15	id=0
0 a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	16	while 1:
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	17	job=self.queue.get()
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	18	if job is None:
a3b6e531f0d2 [svn r93] creating iro package branch Sandro Knauß <knauss@netzguerilla.net> parents: diff changeset	19	break # reached end of queue
20 0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	20	id+=1
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	21	logging.info('ein neuer Job(%d)' %(id))
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	22	try:
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	23	job.start(id)
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	24	logging.info('Job(%d) fertig ;)'%(id))
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	25	except:
0d7ffb9b2c7f logging started Sandro Knauß <knauss@netzguerilla.net> parents: 0 diff changeset	26	logging.exception('Job(%d) fehlgeschlagen :('%(id))

author	Sandro Knauß <knauss@netzguerilla.net>
	Tue, 24 Nov 2009 02:02:41 +0100
changeset 20	0d7ffb9b2c7f
parent 0	a3b6e531f0d2
child 23	0180b538ed74
permissions	-rw-r--r--