executorservice

0熱度

2回答

RejectedExecutionException來自單線程執行程序

下面是我的方法，我有單線程執行程序來執行run方法中的某個任務。 private void trigger(final Packet packet) { // this line is throwing exception Executors.newSingleThreadExecutor().execute(new Runnable() { @Override

java multithreading concurrency runnable executorservice 2017-11-04

---

1熱度

2回答

如何對執行程序服務中運行的代碼片段進行單元測試，而不是等待Thread.sleep（時間）

如何對執行程序服務中運行的代碼進行單元測試？ 在我的情況， public void test() { Runnable R = new Runnable() { @Override public void run() { executeTask1(); executeTask2(); } }; Exec

java unit-testing executorservice 2017-09-24

---

0熱度

1回答

One Producer十個消費者文件處理與Executors.newSingleThreadExecutor（）

我有一個LinkedBlockingQueue任意挑選的容量爲10，並有1000行輸入文件。據我所知，我在服務類的main方法中有一個ExecutorService類型變量，它使用Executors.newSingleThreadExecutor() - 一個單獨的線程調用buffer.readline（），直到文件line == null，然後處理 - 在循環使用Executors.newSin

java multithreading batch-processing executorservice producer-consumer 2017-09-26

---

0熱度

1回答

如何使用純ThreadPoolExecutor獲取MoreExecutors.newDirectExecutorService（）行爲？

當我運行下面的代碼： package foo.trials; import com.google.common.util.concurrent.MoreExecutors; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.Random; import java.util.concurr

guava executorservice 2017-10-05

---

3熱度

1回答

「Runnable :: run」 - 這是如何創建一個Executor實例？

我工作的地方下面的行用於創建一個測試執行成員變量實例的項目： private Executor executor = Runnable::run; 代碼運行和編譯，但我不明白怎麼Runnable::run創建的實例因爲兩者都是不同的接口。 有人能解釋嗎？特別是： 哪裏Runnable接口的實現從何而來？ 它是如何分配給Executor實現的（因爲Executor是不同的接口）？ 什麼樣的Execu

java java-8 runnable executorservice executor 2017-10-06

---

-2熱度

1回答

這段代碼是否線程安全？

private static final Word2Vec word2vectors = getWordVector(); private static Word2Vec getWordVector() { String PATH; try { PATH = new ClassPathResource("models/word2vec_model"

java executorservice 2017-10-07

---

0熱度

1回答

Java調用任務集合（與invokeAll一樣）

我正在尋找一種方法處理javafx.concurrent.Task，java.util.concurrent.Callable和ExecutorService.invokeAll(Collection<? extends Callable<T>>)可以做什麼該方法不能與任務一起使用，因爲它們是可運行的而不是可調用的。 將我的任務類型轉換爲可調用Executors.callable(Runnable

java javafx concurrency task executorservice 2017-10-09

---

0熱度

1回答

ExecutorService動態添加任務

我有10個任務的ExecutorService，並且我想處理24個任務。我可以立即添加前10個任務，但是當某個任務完成時，我想添加另一個任務。 是否有一些最佳實踐，常見方法或模式來實現此行爲？

java executorservice threadpoolexecutor 2017-10-11

---

1熱度

1回答

爲什麼在單線程，雙線程和三線程程序中運行ExecutorService的時間相同？

我正在非常低的溫度下運行薄膜模擬。我嘗試使用ExecutorService正確地多線程我的代碼，並希望減少運行時間。但是我發現了這種說起來容易做起來難的難辦法。我擺弄了許多參數，但無法提高效率。我發現奇怪的是，使用單線程，雙線程或三線程ExecutorService運行代碼的時間幾乎相同。 底線是，儘管for循環的更多迭代同時並行運行，但運行單個迭代所花費的時間卻增加了。無論使用多少個處理器，整體

java multithreading parallel-processing executorservice 2017-10-14

---

0熱度

1回答

如何根據條件關閉Java ScheduledExecutorService？

我遇到了一種停止運行週期性後臺任務的Java ScheduledExecutorService的方法，時間限制在this論壇討論之後。 在我的情況下，當某些條件爲真時，我需要停止ScheduledExecutorService。例如，一旦計數超過5，我想停止打印「beep {count}」。爲此，我使用了以前突出顯示的示例。 public class BeeperControl { pr

java executorservice scheduledexecutorservice 2017-10-16

---