# | Line 265 | Line 265 | public class FutureTask<V> implements Fu | |
---|---|---|
265 | return; | |
266 | try { | |
267 | runner = Thread.currentThread(); | |
268 | < | if (getState() == RUNNING) |
268 | > | if (getState() == RUNNING) // recheck after setting thread |
269 | innerSet(callable.call()); | |
270 | else | |
271 | < | runner = null; |
271 | > | releaseShared(0); // cancel |
272 | } catch (Throwable ex) { | |
273 | innerSetException(ex); | |
274 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |