Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/python2.6
from multiprocessing import Process,Queue
from Queue import Empty
from threading import Thread

import time
import random
import string

class Processing:
        work_queue = Queue()
        stop = False
        count = 0
        start = time.time()
        
        def pudding(self,id): #zum erzeugen von arbeit
                #print 'pudding_start',id
                while not self.stop:
                        text = ''.join(random.choice(string.letters) for i in xrange(8))
                        #print text, id
                        self.work_queue.put((text,id))
                        time.sleep(0.5)
                print 'pudding stopping'
        
        def do_work(self,q,j): #zum abarbeiten
                print 'do_work_start, queue size: ', q.qsize(), ' prozessorID: ', j
                while not self.stop:
                        if self.count == 10000:
                                self.stop = True
                                print time.time()-start, self.count
                        try:
                                x = q.get_nowait()
                                #print x[0],x[1], q.qsize()
                                self.count += 1
                        except Empty:
                                time.sleep(0.1)
                print 'do_work stopping', j
                                
        def prozessor(self,j):
                print 'prozessor', j , 'starten'
                arbeit_schaffen = [Thread(target = self.pudding, args=(i,)) for i in xrange(500)]
                abarbeiten = Thread(target = self.do_work, args=(self.work_queue,j,))
                for p in arbeit_schaffen:
                        p.start()
                abarbeiten.start()
                print 'prozessor', j , 'gestartet'
                
        def start(self):
                prozessor = [Process(target = self.prozessor, args=(j,) ) for j in range(2)]
                for p in prozessor:
                        p.start()
                
                print 'gestartet'
                for p in prozessor:
                        p.join()

start = time.time()
test= Processing()
test.start()
print time.time() - start

Code: Alles auswählen

bj@s8n:~$ python2.6 forum6.py
prozessor 0 starten
prozessor 1 starten
gestartet
Process Process-2:
Traceback (most recent call last):
  File "/usr/lib/python2.6/multiprocessing/process.py", line 231, in _bootstrap
    self.run()
  File "/usr/lib/python2.6/multiprocessing/process.py", line 88, in run
    self._target(*self._args, **self._kwargs)
  File "forum6.py", line 44, in prozessor
    p.start()
  File "/usr/lib/python2.6/threading.py", line 471, in start
    _start_new_thread(self.__bootstrap, ())
error: can't start new thread
Process Process-1:
Traceback (most recent call last):
  File "/usr/lib/python2.6/multiprocessing/process.py", line 231, in _bootstrap
    self.run()
  File "/usr/lib/python2.6/multiprocessing/process.py", line 88, in run
    self._target(*self._args, **self._kwargs)
  File "forum6.py", line 44, in prozessor
    p.start()
  File "/usr/lib/python2.6/threading.py", line 471, in start
    _start_new_thread(self.__bootstrap, ())
error: can't start new thread
0.818915128708