Das deutsche Python-Forum

Code: Alles auswählen

import queue
import threading
import time

def worker():
	global finishedItems
	while(True):
	# do something with the element of the queue q
		try:
			element=q.get(False)
		except queue.Empty:
			break
		finishedItems +=1
		time.sleep(1)

def log():
	global finishedItems
	while(True):
		time.sleep(5)
		print("Finshed items: "+str(finishedItems))
		if q.empty():
			 break

finishedItems=0
q=queue.Queue()
for i in range(100000):
    q.put(i)

for i in range(5):
    x=threading.Thread(target=worker)
    x.start()

logThread = threading.Thread(target=log )
logThread.start()
logThread.join()

Code: Alles auswählen

import queue
import threading
import time

def worker(queue,lock):

    global finished_items
    while True:
    # do something with the element of the queue q
        try:
            lock.acquire()
            element=queue.get(False)
            lock.release()
        except queue.Empty:
            break
        finally:
            lock.release()

        finished_items +=1
        time.sleep(1)

def log(queue):
    global finished_items
    while True:
        time.sleep(5)
        print("Finished items: %s" % str(finished_items))
        if queue.empty():
            break

if __name__ == "__main__":
    lock = threading.Lock()
    finished_items=0
    worker_queue=queue.Queue()

    for i in range(100000):
        worker_queue.put(i)

    for i in range(5):
        worker_thread=threading.Thread(target=worker,args=(worker_queue,lock))
        worker_thread.start()

    log_thread = threading.Thread(target=log, args=(worker_queue,) )
    log_thread.start()
    log_thread.join()