Commit 315c68ef authored by Georgios Dagkakis's avatar Georgios Dagkakis

correction in Queue for more robust synching

parent 5a5c27bf
......@@ -128,12 +128,15 @@ class Queue(CoreObject):
self.canDispose=self.env.event()
# if the event that activated the thread is canDispose then signalReceiver
if self.haveToDispose():
# self.printTrace(self.id, attemptSignalReceiver='(generator)')
if self.receiver:
if not self.receiver.entryIsAssignedTo():
self.signalReceiver()
# try to signal receiver. In case fo failure signal giver (for synchronization issues)
if not self.signalReceiver():
self.signalGiver()
continue
self.signalReceiver()
if not self.signalReceiver():
# try to signal receiver. In case fo failure signal giver (for synchronization issues)
self.signalGiver()
# =======================================================================
# checks if the Queue can accept an entity
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment