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