Python_all_Programs/queued_thread.py at main · radadiavasu/Python_all_Programs · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
import queue
import time
import random

from threading import Thread

counter = 0
job_queue = queue.Queue()
counter_queue = queue.Queue()

def increment_manager():
    global counter
    while True:
        increment = counter_queue.get()
        time.sleep(random.random())
        old_counter = counter
        time.sleep(random.random())
        counter = old_counter + increment
        time.sleep(random.random())
        job_queue.put((f'New counter value is {counter}', '---------'))
        time.sleep(random.random())
        counter_queue.task_done()

Thread(target=increment_manager, daemon=True).start()

def printer_manager():
	while True:
		for line in job_queue.get():
			time.sleep(random.random())
			print(line)
		job_queue.task_done()

Thread(target=printer_manager, daemon=True).start()

def increment_counter():
    counter_queue.put(1)
    time.sleep(random.random())

worker_threads = [Thread(target=increment_counter) for thread in range(10)]


for thread in worker_threads:
	time.sleep(random.random())
	thread.start()

for thread in worker_threads:
	thread.join()

counter_queue.join()
job_queue.join()