executors

2熱度

2回答

我正在運行下面的程序，其中主線程完成第1，在調用子可調用線程的get方法之前。 public class Main { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService exec = Executors.newFi

0熱度

2回答

Java執行程序在特定時間的時間範圍

我需要在規定的時間範圍內每x小時調用一次任務並每天重複此操作。我唯一的想法是計算執行時間作爲從當前時間的延遲，並通過scheduleAtFixedRate和24小時的速率在分離的線程中開始。有沒有人有更好的主意？問候

2熱度

1回答

執行器與Jsoup遞歸

我想申請ExecutorService從遞歸讀取路徑從url中給出的格式，我有困難試圖回憶遞歸 getRecursive（element.attr（「abs：href」），level）; public class NewClass { static String levels[] = {"div.col-md-9 li a", "div#sidebar ul li a"};

0熱度

1回答

在並行框架

使用shutdownNow時。如果我使用Futures像 List<Future<String>> results = executorService.invokeAll(tasks); 或 Future<String> res = executorService.submit(new SingleWorker()); System.out.println(res.get()); 系統等

2熱度

1回答

每個工人使用YARN和Spark的多個執行者？

在我的公司，我們用舊機器和新機器的組合拼湊出異質的YARN + Spark羣集。由於各個機器的統計數據差異很大，我希望能夠在大型機器上啓動多個執行程序。設置--num-executors高於羣集中的機器數量不起作用。是否有其他一些設置需要更改以啓用此功能，還是僅僅是不可能的？

0熱度

1回答

Android：讓線程在AlarmBroarcastReceiver中一個一個排隊排隊

請問您的建議，我是Android編程新手。我正在寫一個類似鬧鐘的軟件，並且使用公共類AlarmManagerBroadcastReceiver擴展BroadcastReceiver 來捕獲AlarmManager之前設置的鬧鐘。爲了不中斷UI，我在這個類的public void onReceive（Context context，Intent intent）中使用了新線程。一般來說它看起來像

0熱度

1回答

一個執行者與一個Jenkins奴隸上的多個執行者之間是否有區別，一次只能運行一個構建？

我有一個jenkins設置與1個主站和4個從站。每個奴隸致力於建立特定的東西（iOS，Android等）。其中一名奴隸致力於幾項工作，每項工作大約需要一個小時才能完成。從站配置有4個執行程序，兩個作業的權重均爲3.我知道這確保了一次只有一個作業在從站上運行。但是，如果我將奴隸配置爲擁有1個執行者併爲每個工作賦予1的權重，它會有所作爲嗎？這是在這個從機上運行的唯一兩個作業。更多的執行者/體重是否意

2熱度

2回答

Spark應用程序只使用1個執行程序

我使用以下代碼運行應用程序。我不明白爲什麼只有1個執行者在使用，即使我有3個。當我嘗試增加範圍時，我的工作失敗，導致任務管理器失去執行者。在總結中，我看到了shuffle寫入的值，但shuffle讀取值爲0（可能導致所有數據都在一個節點上，並且不需要執行任何shuffle讀取操作）。 val rdd: RDD[(Int, Int)] = sc.parallelize((1 to 10000000

4熱度

1回答

Java Executor框架實現了哪種設計模式？

我的理解是它看起來與Abstract Factory非常相似。注： Executor接口： public interface Executor { public void execute(); } 然後是包含靜態工廠各種Executor實現的Executors類。

0熱度

1回答

如何在Spark scala中的執行者之間廣播對象？

我確定我們可以廣播變量的值，但我不知道如何在執行者之間傳播在驅動程序中創建的對象。我在我的Scala程序中爲第三方Java類創建一個對象。我想分享同一個類的實例給所有執行者，而不是創建多個對象。我發現廣播方法可以用來廣播變量的值。但我不知道這是否可以用於廣播對象。請發表您的建議