X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/886b7085ea26ae9500f57e065cd6c1cbc2b5a4ec..385be8f0b1e64c189591bb342a930824d8e9bb6a:/examples/java/app/centralizedmutex/Coordinator.java diff --git a/examples/java/app/centralizedmutex/Coordinator.java b/examples/java/app/centralizedmutex/Coordinator.java index 193129305b..22b3cfd0d4 100644 --- a/examples/java/app/centralizedmutex/Coordinator.java +++ b/examples/java/app/centralizedmutex/Coordinator.java @@ -1,5 +1,4 @@ -/* Copyright (c) 2012-2014, 2016. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2012-2017. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -14,18 +13,16 @@ import org.simgrid.msg.Process; import org.simgrid.msg.MsgException; public class Coordinator extends Process { - LinkedList waitingQueue=new LinkedList<>(); - int csToServe; - public Coordinator(Host host, String name, String[]args) { super(host,name,args); } public void main(String[] args) throws MsgException { - csToServe = Integer.parseInt(args[0]); - Task task; + int csToServe = Integer.parseInt(args[0]); + LinkedList waitingQueue=new LinkedList<>(); + while (csToServe >0) { - task = Task.receive("coordinator"); + Task task = Task.receive("coordinator"); if (task instanceof RequestTask) { RequestTask t = (RequestTask) task; if (waitingQueue.isEmpty()) {