- 浏览: 78553 次
文章分类
最新评论
-
kevinflynn:
...
ThreadLocal 源码分析 -
kevinflynn:
[url=aaaa][/url]
ThreadLocal 源码分析 -
kevinflynn:
学习到了 感谢楼主。
ThreadLocal 源码分析
关于 Future 类 boolean cancel(boolean mayInterruptIfRunning) 的疑问
- 博客分类:
- JAVA 并发
boolean cancel(boolean mayInterruptIfRunning) 方法描述:
/**
* Attempts to cancel execution of this task. This attempt will
* fail if the task has already completed, has already been cancelled,
* or could not be cancelled for some other reason. If successful,
* and this task has not started when <tt>cancel</tt> is called,
* this task should never run. If the task has already started,
* then the <tt>mayInterruptIfRunning</tt> parameter determines
* whether the thread executing this task should be interrupted in
* an attempt to stop the task.
*
* <p>After this method returns, subsequent calls to {@link #isDone} will
* always return <tt>true</tt>. Subsequent calls to {@link #isCancelled}
* will always return <tt>true</tt> if this method returned <tt>true</tt>.
*
* @param mayInterruptIfRunning <tt>true</tt> if the thread executing this
* task should be interrupted; otherwise, in-progress tasks are allowed
* to complete
* @return <tt>false</tt> if the task could not be cancelled,
* typically because it has already completed normally;
* <tt>true</tt> otherwise
*/
但是我实际在进行测试的时候发现,不管传入是 true,还是 false,都会被中断. 这是为啥?
测试代码:
ExecutorService executorService = null;
{
executorService = Executors.newFixedThreadPool(2);
}
@Test
public void cancleTest(){
Future<?> submit = executorService.submit(new Run());
boolean cancel = submit.cancel(false);
System.out.println("是否被取消: " + cancel);
}
@Test
public void cancleTest002(){
Future<?> submit = executorService.submit(new Run());
boolean cancel = submit.cancel(true);
System.out.println("是否被取消: " + cancel);
}
class Run implements Runnable{
public void run() {
System.out.println("Runable 被执行了...");
for (long i = 0; i < 10000000000L; i++) {
System.out.println("iii"+i);
}
System.out.println("我是最后一行...");
}
}
结果:
Runable 被执行了...
iii0
iii1
iii2
iii3
iii4
iii5
iii6
iii7
iii8
iii9
iii10
iii11
iii12
iii13
iii14
iii15
iii16
iii17
iii18
iii19
iii20
iii21
iii22
iii23
iii24
iii25
iii26
iii27
iii28
iii29
iii30
iii31
iii32
iii33
iii34
iii35
iii36
iii37
iii38
iii39
iii40
iii41
iii42
iii43
iii44
iii45
iii46
iii47
iii48
iii49
iii50
iii51
iii52
iii53
iii54
iii55
iii56
iii57
iii58
iii59
iii60
iii61
iii62
iii63
iii64
iii65
iii66
iii67
iii68
iii69
iii70
iii71
iii72
是否被取消: true
iii73
iii74
iii75
iii76
iii77
iii78
iii79
iii80
iii81
iii82
iii83
iii84
iii85
iii86
iii87
iii88
iii89
iii90
iii91
iii92
iii93
iii94
iii95
iii96
iii97
iii98
iii99
iii100
iii101
iii102
iii103
iii104
iii105
iii106
iii107
iii108
iii109
iii110
iii111
iii112
iii113
iii114
iii115
iii116
iii117
iii118
iii119
iii120
iii121
iii122
iii123
iii124
iii125
iii126
iii127
iii128
iii129
iii130
iii131
iii132
iii133
iii134
iii135
iii136
iii137
iii138
iii139
iii140
iii141
iii142
iii143
iii144
iii145
iii146
iii147
iii148
iii149
iii150
iii151
iii152
iii153
iii154
iii155
iii156
iii157
iii158
iii159
iii160
iii161
iii162
iii163
iii164
iii165
iii166
iii167
iii168
iii169
iii170
iii171
iii172
iii173
iii174
iii175
iii176
iii177
iii178
iii179
iii180
iii181
iii182
iii183
iii184
iii185
iii186
iii187
iii188
iii189
iii190
iii191
iii192
iii193
iii194
iii195
iii196
iii197
iii198
iii199
iii200
iii201
iii202
iii203
iii204
iii205
iii206
iii207
iii208
iii209
iii210
iii211
iii212
iii213
iii214
iii215
iii216
iii217
iii218
iii219
iii220
iii221
iii222
iii223
iii224
iii225
iii226
iii227
iii228
iii229
iii230
iii231
iii232
iii233
iii234
iii235
iii236
iii237
iii238
iii239
iii240
iii241
iii242
iii243
iii244
iii245
iii246
iii247
iii248
iii249
iii250
iii251
iii252
iii253
iii254
iii255
iii256
iii257
iii258
iii259
iii260
iii261
iii262
iii263
iii264
iii265
iii266
iii267
iii268
iii269
iii270
iii271
iii272
iii273
iii274
iii275
iii276
iii277
iii278
iii279
iii280
iii281
iii282
iii283
iii284
iii285
iii286
iii287
iii288
iii289
iii290
iii291
iii292
iii293
iii294
iii295
iii296
iii297
iii298
iii299
iii300
iii301
iii302
iii303
iii304
iii305
iii306
iii307
iii308
iii309
iii310
iii311
iii312
iii313
iii314
iii315
iii316
iii317
iii318
iii319
望各位大佬们不吝指点下,感谢!
已解决,junit 框架的问题,代码上的注释没有问题.
/**
* Attempts to cancel execution of this task. This attempt will
* fail if the task has already completed, has already been cancelled,
* or could not be cancelled for some other reason. If successful,
* and this task has not started when <tt>cancel</tt> is called,
* this task should never run. If the task has already started,
* then the <tt>mayInterruptIfRunning</tt> parameter determines
* whether the thread executing this task should be interrupted in
* an attempt to stop the task.
*
* <p>After this method returns, subsequent calls to {@link #isDone} will
* always return <tt>true</tt>. Subsequent calls to {@link #isCancelled}
* will always return <tt>true</tt> if this method returned <tt>true</tt>.
*
* @param mayInterruptIfRunning <tt>true</tt> if the thread executing this
* task should be interrupted; otherwise, in-progress tasks are allowed
* to complete
* @return <tt>false</tt> if the task could not be cancelled,
* typically because it has already completed normally;
* <tt>true</tt> otherwise
*/
但是我实际在进行测试的时候发现,不管传入是 true,还是 false,都会被中断. 这是为啥?
测试代码:
ExecutorService executorService = null;
{
executorService = Executors.newFixedThreadPool(2);
}
@Test
public void cancleTest(){
Future<?> submit = executorService.submit(new Run());
boolean cancel = submit.cancel(false);
System.out.println("是否被取消: " + cancel);
}
@Test
public void cancleTest002(){
Future<?> submit = executorService.submit(new Run());
boolean cancel = submit.cancel(true);
System.out.println("是否被取消: " + cancel);
}
class Run implements Runnable{
public void run() {
System.out.println("Runable 被执行了...");
for (long i = 0; i < 10000000000L; i++) {
System.out.println("iii"+i);
}
System.out.println("我是最后一行...");
}
}
结果:
Runable 被执行了...
iii0
iii1
iii2
iii3
iii4
iii5
iii6
iii7
iii8
iii9
iii10
iii11
iii12
iii13
iii14
iii15
iii16
iii17
iii18
iii19
iii20
iii21
iii22
iii23
iii24
iii25
iii26
iii27
iii28
iii29
iii30
iii31
iii32
iii33
iii34
iii35
iii36
iii37
iii38
iii39
iii40
iii41
iii42
iii43
iii44
iii45
iii46
iii47
iii48
iii49
iii50
iii51
iii52
iii53
iii54
iii55
iii56
iii57
iii58
iii59
iii60
iii61
iii62
iii63
iii64
iii65
iii66
iii67
iii68
iii69
iii70
iii71
iii72
是否被取消: true
iii73
iii74
iii75
iii76
iii77
iii78
iii79
iii80
iii81
iii82
iii83
iii84
iii85
iii86
iii87
iii88
iii89
iii90
iii91
iii92
iii93
iii94
iii95
iii96
iii97
iii98
iii99
iii100
iii101
iii102
iii103
iii104
iii105
iii106
iii107
iii108
iii109
iii110
iii111
iii112
iii113
iii114
iii115
iii116
iii117
iii118
iii119
iii120
iii121
iii122
iii123
iii124
iii125
iii126
iii127
iii128
iii129
iii130
iii131
iii132
iii133
iii134
iii135
iii136
iii137
iii138
iii139
iii140
iii141
iii142
iii143
iii144
iii145
iii146
iii147
iii148
iii149
iii150
iii151
iii152
iii153
iii154
iii155
iii156
iii157
iii158
iii159
iii160
iii161
iii162
iii163
iii164
iii165
iii166
iii167
iii168
iii169
iii170
iii171
iii172
iii173
iii174
iii175
iii176
iii177
iii178
iii179
iii180
iii181
iii182
iii183
iii184
iii185
iii186
iii187
iii188
iii189
iii190
iii191
iii192
iii193
iii194
iii195
iii196
iii197
iii198
iii199
iii200
iii201
iii202
iii203
iii204
iii205
iii206
iii207
iii208
iii209
iii210
iii211
iii212
iii213
iii214
iii215
iii216
iii217
iii218
iii219
iii220
iii221
iii222
iii223
iii224
iii225
iii226
iii227
iii228
iii229
iii230
iii231
iii232
iii233
iii234
iii235
iii236
iii237
iii238
iii239
iii240
iii241
iii242
iii243
iii244
iii245
iii246
iii247
iii248
iii249
iii250
iii251
iii252
iii253
iii254
iii255
iii256
iii257
iii258
iii259
iii260
iii261
iii262
iii263
iii264
iii265
iii266
iii267
iii268
iii269
iii270
iii271
iii272
iii273
iii274
iii275
iii276
iii277
iii278
iii279
iii280
iii281
iii282
iii283
iii284
iii285
iii286
iii287
iii288
iii289
iii290
iii291
iii292
iii293
iii294
iii295
iii296
iii297
iii298
iii299
iii300
iii301
iii302
iii303
iii304
iii305
iii306
iii307
iii308
iii309
iii310
iii311
iii312
iii313
iii314
iii315
iii316
iii317
iii318
iii319
望各位大佬们不吝指点下,感谢!
已解决,junit 框架的问题,代码上的注释没有问题.
发表评论
-
AtomicInteger 源码分析
2019-01-24 16:11 996AtomicInteger 是如何实现原子操作的了? 答案是 ... -
SynchronousQueue 源码初步分析
2019-01-23 16:56 1235简介: 就是一个 put 操作必须和 take 操作对应. 如 ... -
LinkedBlockingDeque 源码分析
2019-01-22 16:44 1492简介: LinkedBlockingDeque 是一个双端队 ... -
CopyOnWriteArrayList 源码分析
2019-01-19 16:02 1367简介: 写操作时上锁,然后拷贝一个新的数组,操作新数组,将当 ... -
CyclicBarrier 源码分析
2019-01-19 13:55 1512简介: CyclicBarrier 实现这么一个功能,比如说吃 ... -
Semaphore 源码分析
2019-01-18 17:53 1369介绍: Semaphore 用于对某一物理或逻辑资源被同一时间 ... -
ThreadPoolExecutor 源码分析
2019-01-16 11:10 2123首先说明的是,这个和 ReadWriteLock 一样,同样是 ... -
分析 Java 任务的执行
2019-01-13 20:26 2052Java 并发中会大量使用到多线程,那么Java是如何使用多线 ... -
BlockingQueue 源码分析
2019-01-13 20:19 1326public interface BlockingQueue& ... -
LinkedBlockingQueue源码分析
2019-01-13 20:16 640LinkedBlockingQueue 其实实现的是一个生产者 ... -
FutureTask WaitNode 源码分析
2019-01-11 17:24 1968waiter 存放等待的线程,这是一个单链表,没有用 lock ... -
关于 Future 类 boolean cancel(boolean mayInterruptIfRunning) 的疑问
2019-01-11 09:07 0boolean cancel(boolean mayInter ... -
InheritableThreadLocal 源码分析
2019-01-07 11:58 1288/* * Copyright (c) 1998, 2004, ... -
ThreadLocal 源码分析
2019-01-05 16:18 2328说明: 每个线程内部持有一个 ThreadLocalMap ... -
ReentrantReadWriteLock 简介
2019-01-04 15:54 14281.首先说明 ReentrantReadWriteLock 和 ... -
CountDownLatch 源码分析
2019-01-03 18:31 1090思路分析: CountDownLatch 的思路是:首先申 ... -
ConditionObject 类分析
2018-12-24 14:28 648Condition 实现主要通过两个方法. ① await ...
相关推荐
1. `boolean cancel(boolean mayInterruptIfRunning)`:此方法用于尝试取消任务的执行。如果 `mayInterruptIfRunning` 为 true,那么正在执行的任务会被立即中断;如果为 false,那么只有当任务已完成或可取消时才会...
boolean cancel(boolean mayInterruptIfRunning) 取消任务的执行。参数指定是否立即中断任务执行,或者等等任务结束 boolean isCancelled() 任务是否已经取消,任务正常完成前将其取消,则返回true boolean isDone...
4. `boolean cancel(boolean mayInterruptIfRunning)`: 取消任务的执行。如果任务尚未开始或者正在运行,mayInterruptIfRunning参数决定是否中断正在执行的任务。 异步Future机制通常与ExecutorService和Callable...
1. `boolean cancel(boolean mayInterruptIfRunning)`:尝试取消执行中的任务。如果任务已经完成或无法取消,将返回`false`。 2. `boolean isCancelled()`:检查任务是否已被取消。 3. `boolean isDone()`:检查任务...
Future的主要方法包括get()方法可以当任务结束后返回一个结果,如果调用时,工作还没有结束,则会阻塞线程,直到任务执行完毕get(long timeout,TimeUnit unit)做多等待timeout的时间就会返回结果cancel(boolean...
- `cancel(boolean mayInterruptIfRunning)`:尝试取消执行中的任务。 2. **`Future`的实现类** 在Java中,`FutureTask`是`Future`的一个常见实现,它同时实现了`Runnable`接口,因此可以被`ExecutorService`提交...
1. `boolean cancel(boolean mayInterruptIfRunning)`:取消任务,如果可能的话中断正在运行的任务。 2. `boolean isCancelled()`:检查任务是否已被取消。 3. `boolean isDone()`:判断任务是否已完成,包括正常...
- `boolean cancel(boolean mayInterruptIfRunning)`:用于取消任务的执行。如果`mayInterruptIfRunning`为`true`,则尝试中断正在执行的任务;如果任务已经完成或已经取消,此方法将返回`false`。 - `boolean ...
1. `cancel(boolean mayInterruptIfRunning)`: 取消任务,取消成功则返回true,取消失败则返回false。 2. `isCancelled()`: 判断任务是否被取消成功,cancel方法成功则返回true,反之则为false。 3. `isDone()`: ...
1. `boolean cancel(boolean mayInterruptIfRunning)`:尝试取消任务的执行。如果任务已经完成、被取消或无法取消,此操作将失败。如果`mayInterruptIfRunning`为`true`,并且任务正在执行,那么它将尝试中断执行...
boolean cancel(boolean mayInterruptIfRunning); boolean isCancelled(); boolean isDone(); V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws ...
- `boolean cancel(boolean mayInterruptIfRunning)`:尝试取消任务的执行。如果任务尚未开始,或者可以中断正在运行的任务,那么取消操作将成功。 - `boolean isCancelled()`:检查任务是否已被取消。 - `...
boolean cancel(boolean mayInterruptIfRunning) // 如果在任务正常完成前将其取消,则返回 true。 boolean isCancelled() // 如果任务已完成,则返回 true。 boolean isDone() // 如有必要,等待计算完成,...
3. **cancel(boolean mayInterruptIfRunning)**: 取消正在执行的任务。mayInterruptIfRunning参数决定是否中断正在运行的任务。 4. **isDone()**: 检查任务是否已完成。 5. **isCancelled()**: 检查任务是否已被取消...
5. `cancel(boolean mayInterruptIfRunning)`: 可以尝试取消正在执行的任务。如果`mayInterruptIfRunning`为`true`,那么正在执行任务的线程会被中断。即使任务无法被取消,`isCancelled()`在后续调用中仍会返回`...
- `cancel(boolean mayInterruptIfRunning)`:尝试取消正在执行的任务。 在实现网络爬虫时,我们可以使用`Future`来管理每个网页的抓取任务。例如,创建一个`ExecutorService`实例,提交任务(每个任务对应一个网页...
3. `cancel(boolean mayInterruptIfRunning)`: 可以尝试取消正在执行的任务。如果`mayInterruptIfRunning`为`true`,并且任务正在执行,那么它会尝试中断任务。如果任务已经完成或者无法取消,这个方法将返回`false`...
- `cancel(boolean mayInterruptIfRunning)`: 可以尝试取消正在执行的任务,如果可能,中断执行线程。 6. **静态工厂方法:** - `completedFuture`: 创建一个已完成的Future,可以立即返回结果或抛出异常。 - `...
3. **取消任务**:`cancel(boolean mayInterruptIfRunning)` 方法可以取消任务执行。`mayInterruptIfRunning` 参数决定是否立即中断正在执行的任务。 4. **判断是否已取消**:`isCancelled()` 方法用于检查任务是否...