-
Notifications
You must be signed in to change notification settings - Fork 0
/
queue_manager.py
32 lines (25 loc) · 876 Bytes
/
queue_manager.py
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
import queue
class QueueManager:
def __init__(self):
# Create input queue
self.inputQueue = queue.Queue()
# Create outbound queues
self.fanRotateQueue = queue.Queue()
self.fanRPMQueue = queue.Queue()
self.fanStateQueue = queue.Queue()
def load_queue(self, load_value, q_name):
self.get_queue(q_name).put(load_value)
def read_queue(self, q_name):
return self.get_queue(q_name).get()
def get_queue(self, q_name):
if ( q_name == "inputQueue" ):
return self.inputQueue
elif ( q_name == "fanRotateQueue" ):
return self.fanRotateQueue
elif ( q_name == "fanRPMQueue" ):
return self.fanRPMQueue
elif ( q_name == "fanStateQueue" ):
return self.fanStateQueue
else:
print("LOL")
return 0