DD.*_*DD. 5 java multithreading executorservice
我目前有一个预定的执行程序,在这样的延迟后发送一条消息:
executor.schedule(new Runnable() {
public void run() {
emitter.emit( message );
}
}, delay, TimeUnit.MILLISECONDS);
Run Code Online (Sandbox Code Playgroud)
我需要另一个线程,它将侦听取消消息,该消息将发送不同的消息,我需要停止上述消息发送.如果没有收到取消消息,则上述正常发送.什么是最好的方法呢?
谢谢.
这可以通过使用返回值来完成
ScheduledFuture<?> future = executor.schedule(new Runnable() {
public void run() {
emitter.emit( message );
}
}, delay, TimeUnit.MILLISECONDS);
future.cancel(true); //true if task should be interrupted
Run Code Online (Sandbox Code Playgroud)
或者使用执行程序的shutdown()方法.
看看shutdown()和cancel()
| 归档时间: |
|
| 查看次数: |
4651 次 |
| 最近记录: |