| changeset 54 | 9774768ef3f0 |
| parent 48 | 32763e344d3b |
| child 55 | ae3669fef3b0 |
| 53:3d072d599ba4 | 54:9774768ef3f0 |
|---|---|
9 def __init__(self,queue): |
9 def __init__(self,queue): |
10 Process.__init__(self) |
10 Process.__init__(self) |
11 self.queue=queue |
11 self.queue=queue |
12 |
12 |
13 def run(self): |
13 def run(self): |
14 logger.info('Workerprocess läuft nun...') |
|
15 id=0 |
14 id=0 |
16 while 1: |
15 while 1: |
17 job=self.queue.get() |
16 job=self.queue.get() |
18 if job is None: |
17 if job is None: |
19 break # reached end of queue |
18 break # reached end of queue |