ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/jsr166y/ForkJoinTask.java
(Generate patch)

Comparing jsr166/src/jsr166y/ForkJoinTask.java (file contents):
Revision 1.59 by jsr166, Tue Sep 7 07:51:13 2010 UTC vs.
Revision 1.61 by jsr166, Thu Sep 16 03:57:13 2010 UTC

# Line 206 | Line 206 | public abstract class ForkJoinTask<V> im
206  
207      /**
208       * Records exception and sets exceptional completion.
209 <     *
209 >     *
210       * @return status on exit
211       */
212      private void setExceptionalCompletion(Throwable rex) {
# Line 223 | Line 223 | public abstract class ForkJoinTask<V> im
223          int s;         // the odd construction reduces lock bias effects
224          while ((s = status) >= 0) {
225              try {
226 <                synchronized(this) {
226 >                synchronized (this) {
227                      if (UNSAFE.compareAndSwapInt(this, statusOffset, s,SIGNAL))
228                          wait();
229                  }
# Line 243 | Line 243 | public abstract class ForkJoinTask<V> im
243          int s;
244          if ((s = status) >= 0) {
245              try {
246 <                synchronized(this) {
246 >                synchronized (this) {
247                      if (UNSAFE.compareAndSwapInt(this, statusOffset, s,SIGNAL))
248                          wait(millis, 0);
249                  }
# Line 261 | Line 261 | public abstract class ForkJoinTask<V> im
261      private void externalAwaitDone() {
262          int s;
263          while ((s = status) >= 0) {
264 <            synchronized(this) {
264 >            synchronized (this) {
265                  if (UNSAFE.compareAndSwapInt(this, statusOffset, s, SIGNAL)){
266                      boolean interrupted = false;
267                      while (status >= 0) {
# Line 698 | Line 698 | public abstract class ForkJoinTask<V> im
698                          long ms = nt / 1000000;
699                          int ns = (int) (nt % 1000000);
700                          try {
701 <                            synchronized(this) {
701 >                            synchronized (this) {
702                                  if (status >= 0)
703                                      wait(ms, ns);
704                              }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines