...
No Format |
---|
@Override public void bsp( BSPPeer<NullWritable, NullWritable, NullWritable, NullWritable, IntWritable> peer) throws IOException, SyncException, InterruptedException { if (isMaster) { Random random = new Random(); // produces new random integers every second while (true) { int newInt = random.nextInt(); // just send to other not master peers peer.send(peer.getAllPeerNames()[Math.abs(newInt % (peer.getNumPeers()-1))+1], new IntWritable(newInt)); System.out.println("Sending " + newInt); peer.sync(); Thread.sleep(1000); } } else { // if I'm not the master, then I am one of the slaves! while (true) { peer.sync(); IntWritable msg = null; while ((msg = peer.getCurrentMessage()) != null) { System.out.println(msg.get() + " received!"); } } } } |
...