Peter Surda
59f3a2fbe7
- rearranged code to reduce cyclic dependencies - doCleanShutdown is separated in shutdown.py - shared queues are separated in queues.py - some default values were moved to defaults.py - knownnodes partially moved to knownnodes.py
17 lines
615 B
Python
17 lines
615 B
Python
import Queue
|
|
from multiprocessing import Queue as mpQueue, Lock as mpLock
|
|
from class_objectProcessorQueue import ObjectProcessorQueue
|
|
|
|
workerQueue = Queue.Queue()
|
|
UISignalQueue = Queue.Queue()
|
|
addressGeneratorQueue = Queue.Queue()
|
|
# receiveDataThreads dump objects they hear on the network into this queue to be processed.
|
|
objectProcessorQueue = ObjectProcessorQueue()
|
|
apiAddressGeneratorReturnQueue = Queue.Queue(
|
|
) # The address generator thread uses this queue to get information back to the API thread.
|
|
|
|
parserProcess = None
|
|
parserLock = mpLock()
|
|
parserInputQueue = mpQueue()
|
|
parserOutputQueue = mpQueue()
|