ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/jsr166y/Phaser.java

Comparing jsr166/src/jsr166y/Phaser.java (file contents):
Revision 1.32 by jsr166, Wed Aug 19 17:44:45 2009 UTC vs.
Revision 1.33 by jsr166, Wed Aug 19 18:00:55 2009 UTC

#	Line 95 | Line 95 | import java.util.concurrent.locks.LockSu
95		* first register, then start the actions, then deregister, as in:
96		*
97		*  <pre> {@code
98	<	* void runTasks(List<Runnable> list) {
98	>	* void runTasks(List<Runnable> tasks) {
99		*   final Phaser phaser = new Phaser(1); // "1" to register self
100		*   // create and start threads
101	<	*   for (Runnable r : list) {
101	>	*   for (Runnable task : tasks) {
102		*     phaser.register();
103		*     new Thread() {
104		*       public void run() {
105		*         phaser.arriveAndAwaitAdvance(); // await all creation
106	<	*         r.run();
106	>	*         task.run();
107		*       }
108		*     }.start();
109		*   }
#	Line 116 | Line 116 | import java.util.concurrent.locks.LockSu
116		* for a given number of iterations is to override {@code onAdvance}:
117		*
118		*  <pre> {@code
119	<	* void startTasks(List<Runnable> list, final int iterations) {
119	>	* void startTasks(List<Runnable> tasks, final int iterations) {
120		*   final Phaser phaser = new Phaser() {
121		*     public boolean onAdvance(int phase, int registeredParties) {
122		*       return phase >= iterations || registeredParties == 0;
123		*     }
124		*   };
125		*   phaser.register();
126	<	*   for (Runnable r : list) {
126	>	*   for (Runnable task : tasks) {
127		*     phaser.register();
128		*     new Thread() {
129		*       public void run() {
130		*         do {
131	<	*           r.run();
131	>	*           task.run();
132		*           phaser.arriveAndAwaitAdvance();
133		*         } while(!phaser.isTerminated();
134		*       }

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines