Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import threading
- from queue import Queue
- def mk_threads(threads, target, obj):
- for t in range(threads):
- t = threading.Thread(target=target)
- t.setDaemon(True)
- t.start()
- for i in obj:
- queue.put(i)
- queue.join()
- def myfunc():
- while True:
- num = queue.get()
- print(num)
- queue.task_done()
- mylist = []
- for x in range(10):
- for i in range(10):
- for i in range (10):
- mylist.append(i / 10)
- queue = Queue()
- mk_threads(3, myfunc, mylist)
- print(len(threading.enumerate()))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement