X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/77221c1956de0a119f6dbb04cf81231d6d035203..fd41b2cabc72234362ec02d66b9b24f5754b1200:/examples/java/app/masterworker/Worker.java diff --git a/examples/java/app/masterworker/Worker.java b/examples/java/app/masterworker/Worker.java index 9ca9a2d26a..20113dd7e6 100644 --- a/examples/java/app/masterworker/Worker.java +++ b/examples/java/app/masterworker/Worker.java @@ -25,19 +25,21 @@ public class Worker extends Process { System.exit(1); } - int num = Integer.valueOf(args[0]).intValue(); - //Msg.info("Receiving on 'slave_"+num+"'"); + int num = Integer.parseInt(args[0]); + Msg.debug("Receiving on 'worker_"+num+"'"); while(true) { Task task = Task.receive("worker_"+num); - if (task.getName().equals("finalize")) { + if ("finalize".equals(task.getName())) { break; } - Msg.info("Received \"" + task.getName() + "\". Processing it."); + Msg.info("Received \"" + task.getName() + "\". Processing it (my pid is "+getPID()+")."); try { task.execute(); - } catch (TaskCancelledException e) {} + } catch (TaskCancelledException e) { + e.printStackTrace(); + } } Msg.info("Received Finalize. I'm done. See you!");