В настоящее время у меня есть запланированный исполнитель, который отправляет сообщение с такой задержкой:
executor.schedule(new Runnable() {
public void run() {
emitter.emit( message );
}
}, delay, TimeUnit.MILLISECONDS);
Мне нужен другой поток, который будет прослушивать сообщение об отмене, которое отправит другое сообщение, и мне нужно остановить отправку вышеуказанного сообщения. Если сообщение об отмене не получено, вышеприведенное отправляется как обычно. Какой лучший способ сделать это?
Спасибо.