12
ответов

Исключение Catch в методе Runnable [дубликат]

Я ищу способ поймать исключение NullPointerException в классе Runnable. У меня есть этот метод, называемый run: private void cooccurrence (int contextIndex, int targetIndex) {try {...
вопрос задан: 26 May 2016 16:15
11
ответов

500 Рабочих потоков, какой пул потоков?

Я задаюсь вопросом - ли это лучший способ сделать это. У меня есть приблизительно 500 потоков, которые работают неограниченно долго, но Thread.sleep в течение минуты при выполнении один цикл обработки. ExecutorService es = Исполнители....
вопрос задан: 19 May 2010 09:41
10
ответов

Удаление всех задач из очереди ThreadPoolExecutor

У меня есть этот довольно простой вопрос о ThreadPoolExecutor. У меня следующая ситуация: я должен потреблять объекты из очереди, создавать для них соответствующие рабочие задачи и отправлять их в ...
вопрос задан: 5 November 2009 10:16
7
ответов

Как ожидать всех потоков для окончания, с помощью ExecutorService?

Я должен выполнить некоторое количество задач 4 за один раз, что-то вроде этого: ExecutorService taskExecutor = Executors.newFixedThreadPool (4); в то время как (...) {taskExecutor.execute (новый MyTask ());}//......
вопрос задан: 24 November 2011 20:41
5
ответов

ExecutorService, как ожидать всех задач закончиться

Что состоит в том, чтобы быть самый простой путь ожидать всех задач ExecutorService закончиться? Моя задача, прежде всего, вычислительна, таким образом, я просто хочу выполнить большое количество заданий - один на каждом ядре. Прямо сейчас моя установка..
вопрос задан: 16 February 2017 03:37
5
ответов

Невозможный сделать кэшируемый пул потоков с пределом размера?

Это, кажется, невозможно сделать кэшируемый пул потоков с пределом количеству потоков, которые это может создать. Вот то, как статический Executors.newCachedThreadPool реализован в стандартном Java...
вопрос задан: 2 March 2016 13:33
5
ответов

Executor.shutdown () все еще ждет выполнения задач без invokeAll или waitTermination [duplicate]

Как сказано в этом ответе: ExecutorService попытается дождаться завершения всех задач, но если shutdown () является последней строкой кода до того, как ваш основной метод завершится, System.exit () будет ...
вопрос задан: 18 November 2013 23:08
5
ответов

Исполнители Java: ожидайте завершения задачи. [дубликат]

Я должен отправить много задач и затем ожидать их, пока все результаты не доступны. Каждый из них добавляет Строку к Вектору (который синхронизируется по умолчанию). Затем я должен запустить новую задачу для...
вопрос задан: 23 April 2013 18:13
5
ответов

Поиск универсальной асинхронной платформы выполнения задания Java / библиотека

Я ищу универсальную асинхронную платформу выполнения задания Java, которая могла обработать Callables или Runnables. Это было бы подобно java.util.concurrent. ExecutorService, (и возможно переносятся...
вопрос задан: 4 March 2009 22:00
4
ответа

Таймер Java по сравнению с ExecutorService?

У меня есть код, где я планирую задачу с помощью java.util. Таймер. Я озирался и видел, что ExecutorService может сделать то же. Так этот вопрос здесь, имейте Вас используемый Таймер и ExecutorService для планирования...
вопрос задан: 17 October 2019 15:14
4
ответа

Обрабатывание исключений от задач Java ExecutorService

Я пытаюсь использовать класс ThreadPoolExecutor Java для выполнения большого количества тяжелых задач веса с постоянным числом потоков. Каждая из задач имеет много мест, во время которых она может перестать работать из-за...
вопрос задан: 20 June 2017 05:01
4
ответа

Какова самая быстрая циклическая синхронизация в Java (ExecutorService по сравнению с CyclicBarrier по сравнению с X)?

Какая конструкция синхронизации Java, вероятно, обеспечит лучшую производительность для параллельного, повторяющегося сценария обработки с постоянным числом потоков как тот, обрисованный в общих чертах ниже? После...
вопрос задан: 27 September 2012 22:26
4
ответа

Удивительная точка безубыточности производительности ExecutorService — эмпирические правила?

Я пытаюсь выяснить, как правильно использовать Исполнителей Java. Я понимаю, что отправляющие задачи к ExecutorService имеют его собственные издержки. Однако я удивлен видеть, что это столь же высоко как есть мой...
вопрос задан: 19 December 2011 22:13
4
ответа

ScheduledExecutorService с переменной задержкой

Предположим, что у меня есть задача, которая вытягивает элементы от java.util.concurrent. BlockingQueue и обработка их. общественность освобождает scheduleTask (международная задержка, TimeUnit timeUnit) {scheduledExecutorService....
вопрос задан: 5 October 2009 10:06
4
ответа

Исполнители Java: как я могу остановить отправленные задачи?

Я утверждал, что задача с помощью исполнителей и мне нужен он для остановки через какое-то время (например, 5 минут). Я попытался делать как это: для (будущее <?> будущее: e.invokeAll (задачи, 300, TimeUnit. СЕКУНДЫ)) {...
вопрос задан: 13 September 2009 16:17
3
ответа

ExecutorService (конкретно ThreadPoolExecutor) ориентирован на многопотоковое исполнение?

ExecutorService гарантирует потокобезопасность? Я буду отправлять задания от различных потоков до того же ThreadPoolExecutor, сделайте я должен синхронизировать доступ к исполнителю прежде, чем взаимодействовать/...
вопрос задан: 6 November 2018 12:43
3
ответа

В том, какие случаи делают Future.get () бросают ExecutionException или InterruptedException

Мой фрагмент кода: исполнитель ExecutorService = Executors.newSingleThreadExecutor (); попробуйте {Задачу t = новая Задача (ответ, inputToPass, pTypes, unit.getInstance (), methodName, unit.getUnitKey ()); Future&...
вопрос задан: 5 July 2016 14:39
3
ответа

Как получить идентификатор потока от пула потоков?

У меня есть фиксированный пул потоков, что я отправляю задачи (ограниченный 5 потоками). Как я могу узнать, какой из тех 5 потоков выполняет мою задачу (что-то как "поток № 3 5 делает эту задачу")?...
вопрос задан: 18 April 2016 13:39
3
ответа

Как перехватывать исключения в FutureTask

Обнаружив, что FutureTask, запущенный в Executors.newCachedThreadPool () на Java 1.6 (и из Eclipse), проглатывает исключения в Runnable. Метод run (), я попытался найти способ поймать ...
вопрос задан: 26 July 2013 08:18
3
ответа

что заставило бы единственного исполнителя задачи прекратить обрабатывать задачи?

Я использую java.util.concurrent. ExecutorService, который я получил путем вызова Executors.newSingleThreadExecutor (). Этот ExecutorService может иногда прекращать обрабатывать задачи, даже при том, что это не было...
вопрос задан: 19 July 2012 04:27
3
ответа

java.util.concurrent. Future.get () не возврат

У меня есть следующий код Java: заключительное будущее будущее = exeService.submit (новый Выполнимый () {общественность освобождают выполненный () {myObject.doSomething (); }}); future.get (); где...
вопрос задан: 6 April 2010 15:26
3
ответа

Управление порядком выполнения Задачи с ExecutorService

У меня есть процесс, который делегирует асинхронные задачи к пулу потоков. Я должен удостовериться, что определенные задачи выполняются в порядке. Таким образом, например, Задачи прибывают в порядок Задачи a1, b1, c1, d1, e1, a2...
вопрос задан: 28 January 2010 10:08
2
ответа

Блок ThreadPoolExecutor, когда очередь заполнена?

Я пытаюсь выполнить множество задач с использованием ThreadPoolExecutor , Ниже приведен гипотетический пример: def workQueue = new ArrayBlockingQueue (3, false) def threadPoolExecutor = new ...
вопрос задан: 19 March 2019 18:02
2
ответа

Java: Таймер и поток это создает

У меня есть этот вопрос: у Меня есть таймер. С scheduleAtFixedRate это создает новую задачу Таймера. В той задаче таймера существует определенный код, который может требовать времени к полному. Как я могу удостовериться это...
вопрос задан: 7 September 2017 03:00
2
ответа

Executors.newCachedThreadPool () по сравнению с Executors.newFixedThreadPool ()

newCachedThreadPool () по сравнению с newFixedThreadPool (), Когда я должен использовать один или другой? Какая стратегия лучше с точки зрения использования ресурса?
вопрос задан: 25 July 2017 16:09
2
ответа

Как дать имя вызываемому Потоку? [дубликат]

Я выполняю Вызываемое использование Объекта пул потоков ExecutorService. Я хочу дать имя этому потоку. Чтобы быть точнее, в более старой версии я сделал это - поток Потока = новый поток (выполнимая Задача);...
вопрос задан: 19 June 2016 03:47
2
ответа

Каковы преимущества использования ExecutorService?

В чем преимущество использования ExecutorService перед запущенными потоками, передающими Runnable в конструктор Thread?
вопрос задан: 21 October 2010 19:31
2
ответа

ExecutorService, который прерывает задачи после тайм-аута

Я ищу реализацию ExecutorService, которой можно предоставить тайм-аут. Задачи, которые отправлены ExecutorService, прерваны, если они занимают больше времени, чем тайм-аут для выполнения...
вопрос задан: 4 May 2010 08:13
2
ответа

Остановите бесконечный цикл в задаче ExecutorService

импорт java.util. Массивы; импорт java.util. Итератор; импорт java.util. Список; импорт java.util.concurrent. Вызываемый; импорт java.util.concurrent. ExecutorService; импорт java.util.concurrent. Исполнители;...
вопрос задан: 1 March 2010 19:16
2
ответа

очереди заданий производителя/потребителя

Я борюсь с лучшим способом реализовать мой конвейер обработки. Мои производители подают работу к BlockingQueue. На потребительской стороне я опрашиваю очередь, обертываю то, что я вхожу в Выполнимую задачу и отправляю...
вопрос задан: 10 February 2010 00:27