executorservice

4熱度

1回答

如何捕獲CompletableFuture的whenCompleteAsync調用中拋出的RejectedExecutionException？

下面的示例代碼我正在注入一個biconsumer睡眠100毫米作爲一套完整的未來的完成行動。我已經使用whenCompleteAsync方法，通過單獨使用executorService。 executorService是ThreadPoolExecutor與芯池大小5，最大尺寸和5 1. public class CompleteTest { public static void mai

java java-8 future executorservice completable-future 2017-02-21

---

0熱度

1回答

將無狀態bean注入到ScheduledExecutorService的runnable中

我想在部署Glassfish後立即運行一些進程。進程將運行每隔一小時，它包含通過無狀態Bean CarService用的findAll（從數據庫表中讀取數據）表示： @PersistenceContext private EntityManager em; public List<Cars> findAll() { javax.persistence.criteria.Criter

jsf java-ee ejb executorservice 2017-02-22

---

0熱度

1回答

什麼是RxJava中單線程ExecutorService的等價物？

我希望在我的地方單用RxJava螺紋ExecutorService： private ExecutorService executor = Executors.newSingleThreadExecutor(); executor.submit(/* ... */); 我想知道什麼是使用RxJava相當於設置？ 我迄今爲止嘗試： private Subject<MyClass> subjec

java concurrency executorservice rx-java2 2017-02-22

---

0熱度

3回答

Java 8固定線程池是否總是創建一個固定數量的線程？

我正在查看Java 8固定線程池的代碼。這裏有一個小樣本： ExecutorService service = Executors.newFixedThreadPool(100); try { for (int i = 0; i < 10; ++i) { service.submit(() -> "In another thread!"); }

java multithreading executorservice 2017-03-01

---

0熱度

1回答

Java ScheduledExecutorService定期運行

我試圖每分鐘運行一個作業[其中包含3個服務應該平行運行]。以下是我的代碼片段。 ExecutorService service = Executors.newFixedThreadPool(servicesMap.size()); for (Map.Entry entry : servicesMap.entrySet()) { service.submit(new MyService(

java executorservice scheduledexecutorservice 2017-03-02

---

1熱度

1回答

Java-如何正確地停止ScheduledExecutorService

假設在實時下面的代碼使用ScheduledExecutorService每分鐘運行一次。 該作業由startBatch.sh文件觸發。 public class TestScheduledExecutorService { public static void main (String a[]) { ScheduledExecutorService service = nul

java executorservice scheduledexecutorservice 2017-03-02

---

-1熱度

1回答

Java執行器服務連接池

我正在嘗試爲Executor服務使用連接池。 當連接池配置爲initialSize = 3，maxToal = 5，maxIdle = 5時，我遇到了一些問題。 我需要每分鐘處理10個服務。但它每分鐘只選擇5項服務。 如果我爲每分鐘配置INITIALSIZE = 3，maxToal = 10，了maxidle = 10，則其採摘10個服務.. 我是新來的多線程和連接。以下是我的代碼片段。請提供建議

java connection-pooling executorservice apache-commons-dbcp scheduledexecutorservice 2017-03-03

---

1熱度

1回答

具有n個線程和n個相應對象的ExecutorService

我有使用固定線程池的服務，因爲這個繁重任務的多於10個實例對我的服務器來說太多了。 ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(10); 我使用它是這樣的： Runnable command = new Runnable() { @Override public void run()

java multithreading executorservice 2017-03-06

---

1熱度

4回答

ExecutorService添加延遲

我有一個非常簡單的程序，它使用ExecutorService。 我已經設置了否。線程4，但所花的時間是一樣的設置爲2 下面是我的代碼： public class Test { private static final Logger LOGGER = Logger.getLogger("./sample1.log"); @SuppressWarnings("unchecked"

java multithreading executorservice 2017-03-07

---

-1熱度

1回答

執行人的newFixedThreadPool沒有給出預期的結果

我試圖在Scala中執行多個線程和一個簡單的測試，我運行此代碼： Executors.newFixedThreadPool(20).execute(new Runnable { override def run(): Unit = { println("Thread Started!") } }) 至於我能理解，這將創建20個線程並打電話給 打印功能，

java multithreading scala executorservice 2017-03-08

---