| changeset 69 | 67ecea2d9b67 |
| parent 61 | 04dfd43dfecc |
| 68:85fc1e5dea79 | 69:67ecea2d9b67 |
|---|---|
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...') |
|
14 indifier=0 |
15 indifier=0 |
15 while 1: |
16 while 1: |
16 job=self.queue.get() |
17 job=self.queue.get() |
17 if job is None: |
18 if job is None: |
18 break # reached end of queue |
19 break # reached end of queue |