63 |
|
* private final CountDownLatch startSignal; |
64 |
|
* private final CountDownLatch doneSignal; |
65 |
|
* Worker(CountDownLatch startSignal, CountDownLatch doneSignal) { |
66 |
< |
* this.startSignal = startSignal; |
67 |
< |
* this.doneSignal = doneSignal; |
66 |
> |
* this.startSignal = startSignal; |
67 |
> |
* this.doneSignal = doneSignal; |
68 |
|
* } |
69 |
|
* public void run() { |
70 |
< |
* try { |
71 |
< |
* startSignal.await(); |
72 |
< |
* doWork(); |
73 |
< |
* doneSignal.countDown(); |
74 |
< |
* } catch (InterruptedException ex) {} // return; |
70 |
> |
* try { |
71 |
> |
* startSignal.await(); |
72 |
> |
* doWork(); |
73 |
> |
* doneSignal.countDown(); |
74 |
> |
* } catch (InterruptedException ex) {} // return; |
75 |
|
* } |
76 |
|
* |
77 |
|
* void doWork() { ... } |
101 |
|
* private final CountDownLatch doneSignal; |
102 |
|
* private final int i; |
103 |
|
* WorkerRunnable(CountDownLatch doneSignal, int i) { |
104 |
< |
* this.doneSignal = doneSignal; |
105 |
< |
* this.i = i; |
104 |
> |
* this.doneSignal = doneSignal; |
105 |
> |
* this.i = i; |
106 |
|
* } |
107 |
|
* public void run() { |
108 |
< |
* try { |
109 |
< |
* doWork(i); |
110 |
< |
* doneSignal.countDown(); |
111 |
< |
* } catch (InterruptedException ex) {} // return; |
108 |
> |
* try { |
109 |
> |
* doWork(i); |
110 |
> |
* doneSignal.countDown(); |
111 |
> |
* } catch (InterruptedException ex) {} // return; |
112 |
|
* } |
113 |
|
* |
114 |
|
* void doWork() { ... } |