Оптимизация параллельной обработки многих файлов

У меня есть часть программы, обрабатывающая много файлов, где для каждого файла нужно сделать две вещи: сначала некоторую часть файла прочитать и обработать,...

Как приостановить / возобновить все потоки в ExecutorService в Java?

Я отправил кучу заданий в службу executorservice на Java, и я как-то хочу временно приостановить все эти задания. Какой лучший способ сделать это? Как я могу возобновить? Или я делаю это совершенно неправильно? Должен ли я следовать какой-то ...

Как ждать завершения всех потоков, используя ExecutorService?

Исполнитель # shutdownNow ()

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

Наконец, если вы хотите суммировать много чисел, вам не нужно сохранять их и суммировать позже. Вы можете суммировать их, как вы идете.

аюсь выполнить простой расчет (это вызываетMath.random() 10000000 раз). Удивительно, но запуск его простым способом выполняется намного быстрее, чем при использовании ExecutorService. Я прочитал другую ветку наУдивительная точка безубыточности ...

но если необходимо очистить соединение с базой данных, вы не можете просто «никогда не очищать».

ользую кешированный пул потоков ExecutorService для выполнения некоторых асинхронных фоновых задач. Я предоставил свой ThreadFactory, который раздает потоки в ExecutorService (когда это необходимо). Насколько я понимаю, кешированный пул потоков ...

Как назвать потоки пула потоков в Java [дубликаты]

На этот вопрос уже есть ответ: Наименование потоков и пулов потоков ExecutorService [/questions/6113746/naming-threads-and-thread-pools-of-executorservice] 16 ответов У меня есть приложение Java, которое используетExecutor Framework, и у меня ...

Альтернативой для сна ваших потоков является предоставление каждому работнику длинного значения sleepUntil. Когда ваш исполнитель вызывает работника, если он спит, он немедленно возвращается. В противном случае он выполняет свою работу, а затем возвращается. Это может помочь уменьшить счет вашего потока, потому что FixedThreadPoolExecutor сможет обрабатывать гораздо больше рабочих, чем имеет потоки, если большинство из них помечены как спящие и быстро возвращаются.

я довольно большое количество потоков, создаваемых внутри программы clojure: (import '(java.util.concurrent Executors)) (def *pool* (Executors/newCachedThreadPool)) (defn do-something [] ; work Thread/sleep 200 ; repeat) (dotimes [i 10000] ...

ждать, пока все потоки не закончат свою работу в Java

ользуюExecutorService выполнить задачу. Эта задача может рекурсивно создавать другие задачи, которые передаются в тот жеExecutorService и эти дочерние задачи тоже могут это делать. Теперь у меня есть проблема, которую я хочу подождать, пока все ...

 брошен)

аюсь закодировать решение, в котором один поток создает задачи с интенсивным вводом-выводом, которые могут выполняться параллельно. Каждая задача имеет значительные данные в памяти. Поэтому я хочу иметь возможность ограничить количество задач, ...