futuretask

    7熱度

    2回答

    我有這樣一種服務: class DemoService { Result process(Input in) { filter1(in); if (filter2(in)) return... filter3(in); filter4(in); filter5(in); return ... } }

    1熱度

    1回答

    我試圖運行一個異步過程並獲取它的輸入流(如果有的話)。 這是我的代碼: CommandCall commandCall = new CommandCall(commands); ExecutorService executor = Executors.newSingleThreadExecutor(); Future<Integer> task = executor.submi

    0熱度

    1回答

    有沒有什麼理由使用其中一種?他們似乎都以不同的方式做同樣的事情。我可以看到FutureTask更具可擴展性,但對於一個簡單的任務,我希望返回未來以便稍後獲取值,是否有區別?

    5熱度

    1回答

    我需要找到一種方法將Future轉換爲ListenableFuture。 目前,我正在使用返回Future的服務,但我需要連接一個監聽器。 我無法更改服務界面,因爲它不屬於我。 有沒有簡單的方法來做到這一點? 我已閱讀番石榴文檔,但仍然找不到辦法做到這一點。

    0熱度

    1回答

    我寫了一個paralellized alghoritm來完成對存儲在Orient表中的數據的計算。 爲了控制內存,我嘗試對這些數據進行分頁,然後嘗試並行化我的alghoritm以提高性能(使用Future任務)。 我東方的設置是: set ORIENTDB_SETTINGS=-Dprofiler.enabled=true -Dstorage.diskCache.bufferSize=12906

    0熱度

    2回答

    我有一個類,它從Swing中裝飾JTextComponent。它包含的方法可以從任何線程調用,所以我必須確保,與JTextComponent一起使用的代碼將由AWT線程執行。 第二個要求是,調用整個方法的線程將「等待」,直到AWT線程完成任務。 public String getSelectedText() { Callable c = new Callable() {

    0熱度

    2回答

    我正在構建一個應用程序,它是根據與服務器通信的Futuretask線程動態填充/清除數組列表。 問題是,當我添加新的對象到我arrayadapter以任何方式我稱之爲notifyDataSetChanged或setNotifyOnChange (例如添加項目之後,我也嘗試做一些postadd函數調用notifyDataSetChanged ,或者甚至試圖在適配器構造函數添加setNotifyOnC

    0熱度

    1回答

    下面是從書中Java併發實踐的片段,我感到困惑: interface Computable<A, V> { V compute(A arg) throws InterruptedException; } public class Memoizer3<A, V> implements Computable<A, V> { private final Map<A, Futu

    0熱度

    1回答

    我在試圖瞭解AsyncTask().get()實際工作方式時遇到問題。我知道這是一個synchronous執行,但是:我不知道​​和get()如何連接。 我從谷歌的文檔此示例代碼: // Async Task Class class DownloadMusicfromInternet extends AsyncTask<String, String, String> { // Sho

    6熱度

    2回答

    我有3 FutureTask<T>對象。我希望他們是異步處理的。然而,一旦FutureTasks'get()方法之一不返回null我想繼續,即我的方法(包裝)返回並不會等待,直到其他兩個FutureTasks處理。 我想到是這樣的: private File wrapper(final File file) { ExecutorService executors = Executors.