154 |
|
private PublicFutureTask(final Runnable runnable, Object result, |
155 |
|
final AtomicInteger runCount) { |
156 |
|
super(new Runnable() { |
157 |
< |
public void run() { |
158 |
< |
runCount.getAndIncrement(); |
159 |
< |
runnable.run(); |
160 |
< |
}}, result); |
157 |
> |
public void run() { |
158 |
> |
runCount.getAndIncrement(); |
159 |
> |
runnable.run(); |
160 |
> |
}}, result); |
161 |
|
this.runCount = runCount; |
162 |
|
} |
163 |
|
PublicFutureTask(Callable callable) { |
172 |
|
}}); |
173 |
|
this.runCount = runCount; |
174 |
|
} |
175 |
< |
public void done() { |
175 |
> |
@Override public void done() { |
176 |
|
assertTrue(isDone()); |
177 |
|
doneCount.incrementAndGet(); |
178 |
|
super.done(); |
179 |
|
} |
180 |
< |
public boolean runAndReset() { |
180 |
> |
@Override public boolean runAndReset() { |
181 |
|
runAndResetCount.incrementAndGet(); |
182 |
|
return super.runAndReset(); |
183 |
|
} |
184 |
< |
public void set(Object x) { |
184 |
> |
@Override public void set(Object x) { |
185 |
|
setCount.incrementAndGet(); |
186 |
|
super.set(x); |
187 |
|
} |
188 |
< |
public void setException(Throwable t) { |
188 |
> |
@Override public void setException(Throwable t) { |
189 |
|
setExceptionCount.incrementAndGet(); |
190 |
|
super.setException(t); |
191 |
|
} |