Commit e5b4f635 authored by Georgios Dagkakis's avatar Georgios Dagkakis Committed by Jérome Perrin

enhancement in BatchDecomposition so that it does not get blocked in the start...

enhancement in BatchDecomposition so that it does not get blocked in the start of on-shift of the successor
parent d0eb3f64
...@@ -127,6 +127,9 @@ class BatchDecomposition(CoreObject): ...@@ -127,6 +127,9 @@ class BatchDecomposition(CoreObject):
# signal the receiver again and break # signal the receiver again and break
if self.signalReceiver(): if self.signalReceiver():
break break
if self.entityRemoved.triggered:
break
# for the consecutive times wait till the receiver is available and then signalReceiver # for the consecutive times wait till the receiver is available and then signalReceiver
# we know that the receiver is occupied with the previous sub-batch # we know that the receiver is occupied with the previous sub-batch
else: else:
...@@ -136,6 +139,10 @@ class BatchDecomposition(CoreObject): ...@@ -136,6 +139,10 @@ class BatchDecomposition(CoreObject):
signaling=self.signalReceiver() signaling=self.signalReceiver()
if signaling: if signaling:
break break
if self.entityRemoved.triggered:
break
self.entityRemoved=self.env.event()
# ======================================================================= # =======================================================================
# removes an entity from the Machine # removes an entity from the Machine
# ======================================================================= # =======================================================================
......
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