Admin: 1 версия

2010-06-01T06:58:24Z

1 версия

в 18:01, 31 мая 2010

2010-05-31T18:01:46Z

Новая страница

== A thread of execution that uses a CyclicBarrier ==



<source lang="java">

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
class BarDemo {
public static void main(String args[]) {
CyclicBarrier cb = new CyclicBarrier(3, new BarAction());
System.out.println("Starting");
new MyThread(cb, "A");
new MyThread(cb, "B");
new MyThread(cb, "C");
}
}
class MyThread implements Runnable {
CyclicBarrier cbar;
String name;
MyThread(CyclicBarrier c, String n) {
cbar = c;
name = n;
new Thread(this).start();
}
public void run() {
System.out.println(name);
try {
cbar.await();
} catch (BrokenBarrierException exc) {
System.out.println(exc);
} catch (InterruptedException exc) {
System.out.println(exc);
}
}
}
class BarAction implements Runnable {
public void run() {
System.out.println("Barrier Reached!");
}
}
public class MainClass {
public static void main(String args[]) {
CyclicBarrier cb = new CyclicBarrier(3, new BarAction());
System.out.println("Starting");
new MyThread(cb, "A");
new MyThread(cb, "B");
new MyThread(cb, "C");
new MyThread(cb, "X");
new MyThread(cb, "Y");
new MyThread(cb, "Z");
}
}
</source>

← Предыдущая	Версия 06:58, 1 июня 2010
(нет различий)

Java/Threads/CyclicBarrier - История изменений

Admin: 1 версия

в 18:01, 31 мая 2010