X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fc783dc02e4e1bf955b152713d1df4914ae3adb8..773834eae5b4c5d52e54bbd464442833dbdcfeef:/examples/mutualExclusion/centralized/Coordinator.java diff --git a/examples/mutualExclusion/centralized/Coordinator.java b/examples/mutualExclusion/centralized/Coordinator.java index 03da2f63fe..74abea263b 100644 --- a/examples/mutualExclusion/centralized/Coordinator.java +++ b/examples/mutualExclusion/centralized/Coordinator.java @@ -7,13 +7,16 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ +package mutualExclusion.centralized; import java.util.LinkedList; -import simgrid.msg.Msg; -import simgrid.msg.MsgException; -import simgrid.msg.Task; +import org.simgrid.msg.Msg; +import org.simgrid.msg.MsgException; +import org.simgrid.msg.Task; +import org.simgrid.msg.Process; -public class Coordinator extends simgrid.msg.Process { + +public class Coordinator extends Process { LinkedList waitingQueue=new LinkedList(); int CsToServe; @@ -30,7 +33,7 @@ public class Coordinator extends simgrid.msg.Process { GrantTask tosend = new GrantTask(); tosend.send(t.from); } else { - waitingQueue.push(t); + waitingQueue.addFirst(t); } } else if (task instanceof ReleaseTask) { if (!waitingQueue.isEmpty()) { @@ -45,4 +48,4 @@ public class Coordinator extends simgrid.msg.Process { } } } -} \ No newline at end of file +}