executor
Я использую ScheduledExecutorService для выполнения задачи, которая вызывает службу с фиксированной скоростью. Служба может возвращать некоторые данные в задачу. Задача хранит данные в очереди. Некоторые другие потоки медленно выбирают элементы из очереди import java.util.concurrent.BlockingQueue; import jav...
У меня есть эта проблема, у меня есть private ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); И задача, которая создается каждые 50 миллисекунд: executor.scheduleAtFixedRate(myTask, 0, 50, TimeUnit.MILLISECONDS); myTask Иногда требуется некоторое время для зав...
Я хочу создать ThreadPoolExecutor таким образом, когда он достиг своего максимального размера и очередь заполнена,submit() метод блокируется при попытке добавить новые задачи. Мне нужно реализовать пользовательский RejectedExecutionHandler для этого и существует способ сделать это с помощью стандартной библио...
исполнитель кажется чистой абстракцией. Когда вы хотите использовать поток напрямую, а не полагаться на более надежного исполнителя?...