取消预定的执行者

发布于 2024-12-01 05:31:52 字数 332 浏览 0 评论 0原文

我目前有一个预定的执行程序，它在延迟后发出一条消息，如下所示：

        executor.schedule(new Runnable() {
            public void run() {
                emitter.emit( message );
            }
        }, delay, TimeUnit.MILLISECONDS);

我需要另一个线程来侦听取消消息，该取消消息将发送不同的消息，并且我需要停止发送上述消息。如果没有收到取消消息，则上述内容将正常发送。最好的方法是什么？

谢谢。

原文

I currently have a scheduled executor which sends out a message after a delay like this:

        executor.schedule(new Runnable() {
            public void run() {
                emitter.emit( message );
            }
        }, delay, TimeUnit.MILLISECONDS);

I need to have another thread which will listen for a cancel message which will send a different message and I need to stop the above message from sending. If no cancel message is received the above sends as normal. Whats the best way to do this?

Thanks.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

得不到的就毁灭 2024-12-08 05:31:52

这可以通过使用执行器的返回值

ScheduledFuture<?> future = executor.schedule(new Runnable() {
      public void run() {
         emitter.emit( message );
     }
    }, delay, TimeUnit.MILLISECONDS);
future.cancel(true);  //true if task should be interrupted

或使用执行器的 shutdown() 方法来完成。
看看关闭()
并取消 ()

This can be done by using the return value of

ScheduledFuture<?> future = executor.schedule(new Runnable() {
      public void run() {
         emitter.emit( message );
     }
    }, delay, TimeUnit.MILLISECONDS);
future.cancel(true);  //true if task should be interrupted

or by using the shutdown() method of the executor.
Take a look at shutdown()
and cancel()

回复收藏 0 原文