executor

4熱度

1回答

服務器崩潰/關閉後恢復Asynch ThreadPoolTask​​executor

我有一個Spring Rest控制器，它使用Spring的@Async方法調用異步方法，並立即返回一個http 202代碼（Accepted）給客戶端（異步作業很重並可能導致超時）。 實際上，在異步任務結束時，我向客戶發送一封電子郵件，告訴他他的請求狀態。 一切正常，但我問自己，如果我的服務器/ jvm崩潰或關閉，我該怎麼辦？我的客戶將收到202代碼，並且永遠不會收到狀態電子郵件。 是否有一種方法

java spring asynchronous executor 2016-12-09

---

2熱度

1回答

等待任何未來的asyncio

我想用asyncio來處理併發的網絡I/O。大量的功能將被安排在一個單獨的點上，每個點完成所花費的時間差異很大。接收到的數據然後在每個輸出的獨立過程中處理。 數據處理的順序是不相關的，所以考慮到輸出的潛在非常長的等待期，我希望await可以首先取代預定義順序的任何未來結束。 def fetch(x): sleep() async def main(): futures =

python python-asyncio executor 2016-09-08

---

1熱度

1回答

關閉本地客戶端的hazelcast exector服務

我們正在使用hazelcast執行程序服務在我們的服務器集羣中分發任務。 我們希望關閉其中一臺服務器並將其從羣集中取出，但允許其繼續工作一段時間以完成正在執行的操作，但不接受來自榛木執行器服務的任何新任務。 我不想關閉hazelcast實例，因爲當前任務可能需要它來完成他們的工作。 關閉hazelcast執行器服務不是我想要的。這就關閉了整個集羣的執行者。 我想繼續處理本地隊列中的任務，直到它爲空

executorservice hazelcast shutdown executor 2016-09-13

---

0熱度

1回答

如何在有數千個/動態數量的任務時使用Executor？

我剛剛發現了Java的Executor，我在想它是否適合我的需求。我有一個數據庫，不斷添加任務。 我SQL從數據庫中選擇所有行（任務）。在任何時候，它們可能有100000個，200個，3個或0個。 我看到的例子是這樣的： ExecutorService taskExecutor = Executors.newFixedThreadPool(50); while(...) { taskE

java multithreading threadpoolexecutor executor 2016-11-06

---

2熱度

3回答

我們是否可以在執行器上跨批次使用緩存RDD

我有一種情況，我想每隔一小時從遠程存儲器下載一些數據，並將其作爲鍵值對存儲在執行器/工作者的RDD中。我想緩存這個RDD，以便在此執行者/工作者上運行的所有將來的作業/任務/批處理可以使用緩存的RDD進行查找。這在Spark Streaming中可能嗎？ 一些相關的代碼或指向相關代碼的指針將會有所幫助。

caching apache-spark streaming rdd executor 2016-09-20

---

0熱度

1回答

Spark程序來監視執行程序的性能

我正在開發一個監視每個執行程序性能的火花程序，例如當一個執行程序開始工作時以及完成其工作時標記。我正在考慮兩種方式來做到這一點： 首先，開發程序，這樣當執行程序開始工作時，它將當前時間標記爲文件，當它結束時，將該時間標記爲同一文件。最後，除了驅動程序機器之外，所有「日誌」文件都將散佈在整個集羣網絡中。其次，由於執行者會定期向駕駛員報告，每次駕駛員收到來自執行者的消息時，如果消息包含「開始」和「完成

hadoop apache-spark driver executor bigdata 2016-11-09

---

1熱度

2回答

java執行器框架的invokeAll在Spring執行器中的所有等價方法

在java執行器框架中，等待所有任務完成後我們有invokeAll（）方法。但是在使用spring的ThreadPoolTaskExecutor時，我們只提交返回Future對象的方法。第一個任務是要開始下一個任務。所以如果我想等到所有任務完成後有什麼辦法做到這一點？意思是有沒有在春季可用的方法，它等於invokeAll()請糾正我，如果我的理解是錯的..

spring multithreading executor 2016-11-14

---

3熱度

3回答

的Java newSingleThreadExecutor垃圾收集

考慮下面的Java代碼 void doSomething(Runnable r1, Runnable r2){ Executor executor = Executors.newSingleThreadExecutor(); executor.execute(r1); executor.execute(r2); } 當我調用DoSomething的方法，執行程序

java multithreading executor 2016-09-29

---

0熱度

1回答

重新引發異常的ExecutorService

我需要使用任何Executor或ExecutorService執行任務。任務（Callable或Runnable）應該無限運行，但如果發生任何異常，應該將其重新提交給提交任務的線程。 我知道future.get()會拋出ExecutionException對我來說： ExecutorService executor = Executors.newSingleThreadExecutor();

java exception-handling executorservice executor rethrow 2016-08-21

---

0熱度

1回答

Gitlab-CI多選手開始搬運工容器，腳本現在的工作

亞軍已經啓動泊塢窗容器中，config.toml是： concurrent = 1 check_interval = 0 [[runners]] name = "spring-boot-scripts" url = "http://xxxxx.com/ci" token = "xxxxxx" executor = "docker" build

docker gitlab-ci executor 2016-08-25

---