executor

2熱度

1回答

如何保證ScheduledThreadPoolExecutor的調度不會突然死亡？

我是一個正在解決這個ScheduledThreadPoolExecutor問題的新手程序員。在使用一些Google搜索時，我知道如何使用afterExecute方法處理來自Runnable（）部分的異常。現在它歸結爲這一點。如果ScheduledThreadPoolExecutor的scheduleAtFixedRate（）方法發生錯誤並且線程突然停止，該怎麼辦？換句話說，如果該誤差是執行

0熱度

1回答

如何創建多個線程池（即多個執行程序，每個線程池都有一個線程）

我目前需要創建多個線程池。每個線程池都是一個單線程線程池。根據條件將任務分配給每個線程池。所以我需要跟蹤線程池。我該怎麼做？我可以創建一個線程數組嗎？ ExecutorService executor = Executors.newSingleThreadExecutor(); 這是我們如何創建1個線程池。現在我想創建5個線程池。 ExecutorService[] executor;

0熱度

2回答

星火用長絲流：執行者沒有充分利用

我運行的火花與紗線與流 - 通過DireactStream方法（沒有接收器） spark-submit --master yarn --deploy-mode cluster --num-executors 2 --executor-memory 8g --driver-memory 2g --executor-cores 8 .. 我消耗卡夫卡。我有2個主題（每個有3個分區）。我有一個DSt

0熱度

1回答

spark正在單個執行器上運行多個分區的作業

我有一個運行在Mesos集羣中的Spark 2.1.1作業。 Spark UI顯示了32個活動執行程序，RDD.getNumPartitions顯示了28個分區。但是隻有一個（隨機）執行者正在做任何工作，其他所有人都被標記爲已完成。我添加了執行程序代碼（stdout）的調試語句，只有一個執行程序顯示這些。整個管道結構如下：獲取ID列表 - >爲每個ID下載JSON數據 - >解析JSON數據

0熱度

1回答

執行器沒有完成所有的任務

您好我想運行下面的代碼，並且在執行器被終止後，我期待剩餘任務的計數爲0，但由於某種原因，當它滿足以下條件時它超過100。 while(executor.isTerminated()) { System.out.println("Total Task Remaining : " + ExecutorServiceExample.task.size()); System

2熱度

1回答

方法引用作爲Executor實現

我一直在研究由人編寫的例子Java代碼，面對下面的代碼片段： Runnable runnable =() -> System.out.println("Thread name: " + Thread.currentThread().getName()); Executor executor; executor = Runnable::run; executor.execute(runna

0熱度

1回答

火花執行器登錄IntelliJ IDEA

我正在運行一個火花應用程序，它具有火花在POM中的相關性。而在IntelliJ IDEA中，我只能看到驅動程序端的日誌，但沒有執行程序日誌。我發現在配置中我可以添加日誌文件以顯示在控制檯中，但我需要知道日誌文件的位置...請注意，它在依賴庫中使用spark，但不是我本地的spark環境... 謝謝， Lionel

0熱度

2回答

ExecutorService - 在方法中創建新實例vs每個類創建一個實例

我應該在每個方法調用中創建新的ExecutorService還是每個類使用一個？在性能方面哪個是首選？ public class NotificationService { public void sendNotification(User recipient) { ExecutorService notificationsPool = Executors.newFixe

2熱度

2回答

TomEE中的託管執行程序服務

我有一臺服務器，其中有48個CPU託管TomEE + 7.0.2上的Java EE 7 REST API。某些API需要儘可能多地使用CPU，因爲它們運行的是並行算法。並行化部分不需要任何數據庫或其他資源，只需要在共享double [] []矩陣中進行一些繁重工作。我通常在EJB上下文中工作，但對於這個特定的實例，它不是一個需求（也不是最好的）。到目前爲止我用 ExecutorServ

3熱度

1回答

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

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