Examples of EDU.oswego.cs.dl.util.concurrent.CyclicBarrier.barrier()

Package EDU.oswego.cs.dl.util.concurrent

Class EDU.oswego.cs.dl.util.concurrent.CyclicBarrier

Examples of EDU.oswego.cs.dl.util.concurrent.CyclicBarrier.barrier()

EDU.oswego.cs.dl.util.concurrent.CyclicBarrier.barrier()
Enter barrier and wait for the other parties()-1 threads. @return the arrival index: the number of other parties that were still waiting upon entry. This is a unique value from zero to parties()-1. If it is zero, then the current thread was the last party to hit barrier point and so was responsible for releasing the others. @exception BrokenBarrierException if any other threadin any previous or current barrier since either creation or the last restart operation left the barrier prematurely due to interruption or time-out. (If so, the broken status is also set.) Threads that are noticied to have been interrupted after being released are not considered to have broken the barrier. In all cases, the interruption status of the current thread is preserved, so can be tested by checking Thread.interrupted. @exception InterruptedException if this thread was interruptedduring the barrier, and was the one causing breakage. If so, broken status is also set.

                        MarshalledObject object = client.createMarshalledObject();
                        object.set(text);
                        Msg msg = client.createMsg();
                        msg.pushMarshaledObject(object);
                                
                        barrier.barrier();
                        
                        for(int i=0; i < MESSAGE_COUNT; i++ )         
                            client.sendRequest(connectURI,msg);

View Full Code Here

                /**
                 * @see java.lang.Thread#run()
                 */
                public void run() {
                    try {
                        barrier.barrier();


                        for (int i = 0; i < MESSAGE_COUNT; i++)
                            sp.sendDown(allocateDownPacket());


                    } catch (Exception e) {

View Full Code Here

                /**
                 * @see java.lang.Thread#run()
                 */
                public void run() {
                    try {
                        barrier.barrier();


                        for (int i = 0; i < MESSAGE_COUNT; i++)
                            sp.sendDown(getDatagramPacket());

View Full Code Here

                        MarshalledObject object = client.createMarshalledObject();
                        object.set(text);
                        Msg msg = client.createMsg();
                        msg.pushMarshaledObject(object);
                                
                        barrier.barrier();
                        
                        for(int i=0; i < MESSAGE_COUNT; i++ )         
                            client.sendRequest(connectURI,msg);

View Full Code Here

         public void run() {
            try {
               sem.acquire(); // we're first to the semaphore


               // log("waiting on barrier");
               barrier.barrier(); // wait until t2 joins us
               // log("passed barrier");
               lock=s.readLock();
               lock.attempt(TIMEOUT);
               log("1st read: value is " + value);
               assertEquals(10, value);

View Full Code Here

         Sync lock=null;


         public void run() {
            try {
               TestingUtil.sleepThread(100);
               barrier.barrier();
               sem.acquire();
               lock=s.writeLock();
               lock.attempt(TIMEOUT);
               log("changing value from " + value + " to 20");
               value=20;

View Full Code Here

/* 1380 */               RNG.itersPerBarrier.get() + "Ib : ");
/*      */           }
/*      */ 
/*      */         }
/*      */ 
/* 1389 */         barrier.barrier();
/*      */ 
/* 1391 */         barrier.barrier();
/*      */ 
/* 1393 */         long tm = timer.getTime();
/* 1394 */         long totalIters = nthreads * iters;

View Full Code Here

/*      */ 
/*      */         }
/*      */ 
/* 1389 */         barrier.barrier();
/*      */ 
/* 1391 */         barrier.barrier();
/*      */ 
/* 1393 */         long tm = timer.getTime();
/* 1394 */         long totalIters = nthreads * iters;
/* 1395 */         double dns = tm * 1000.0D * 10.0D / totalIters;
/* 1396 */         long ns = Math.round(dns);

View Full Code Here

                /**
                 * @see java.lang.Thread#run()
                 */
                public void run() {
                    try {
                        barrier.barrier();


                        for (int i = 0; i < MESSAGE_COUNT; i++)
                            sp.sendDown(allocateDownPacket());

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.