callable

    0熱度

    1回答

    我有下面的代碼的類, public class DocTransformer implements Callable<IndexableDocument> { WDoc document; public DocTransformer(Map<INDEXFIELD, Tokenizer> tknizerMap, WDoc doc) { this.document =

    0熱度

    1回答

    我們有一個asmx web服務。我必須使用WSDL測試客戶端。我已經成功實現了客戶端異步映射的代碼。問題是我無法理解客戶端如何向服務器發出多個同時請求。我看到Future接口,但我不明白我如何使用它進行併發呼叫。 private void callAsyncCallback(String encodedString, String key) { DataManipulation ser

    -1熱度

    2回答

    這裏是我的代碼, import numpy as np import math import matplotlib.pyplot as plt #Voltages V,I = np.genfromtxt('Photocurrent_graph_2.csv', dtype=float, delimiter=',', usecols=(0,2), skiprows=1, u

    2熱度

    3回答

    每當我運行我的程序實現可調用,我得到的順序形式的輸出。 喜歡,這是我的程序: package com.handson; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import

    0熱度

    2回答

    我很難嘗試以我想要的方式正確編程我的應用程序。 當前,我的應用程序(作爲Java Servlet)將查詢數據庫以查找要處理的項目列表。對於列表中的每個項目,它都會提交一個HTTP Post請求。我試圖創建一種方法,在用戶請求的情況下,我可以停止此處理(甚至終止進行中的HTTP Post請求)。可以有同時處理不同查詢的線程。現在,我將停止在所有線程中處理。 我目前的嘗試涉及在Callable類中實現

    1熱度

    1回答

    所以我已經解決了一些問題,通過在這裏獲得幫助,以及來自我認識的人的 。我的問題的根源是,我不知道如何包裝無如此 ,我不會收到這些錯誤沒有屬性,或不可調用。 對於這個鏈表,我真正需要的是插入和打印列表。 我沒有列入打印列表,因爲它很簡單,並且不會造成問題。 錯誤在Linked_List下,在插入下,在elif下。 它的註釋,以便:#< ----錯誤 下面是代碼: class Node: def _

    16熱度

    2回答

    假設我想運行靜態方法foo異步 void foo() throws Exception {...} 由於foo拋出一個異常,我寧願創建Callable並調用ExecutorService.submit用它來獲得一個Future。 現在我想知道如何正確申報Callable和Future。 我應該聲明他們 Callable<Void> and Future<Void>?

    0熱度

    1回答

    我想要做這樣的事情: public class MyCallable implements Callable<Boolean>, MyObserver { Boolean mSuccess = false; @Override public Boolean call() throws Exception { // ... Wait here

    0熱度

    4回答

    我想創建一個具有固定線程池大小的singleton-ExecutorService。另一個線程將用Callables提供該ExecutorService,並且我想在執行完成後立即解析Callables的結果(最佳)。 我真的不確定如何正確實施。 我最初的想法是單例ES中的一種方法,它通過「submit(callable)」將一個Callable添加到ExecutorService中,並將結果Fut

    0熱度

    1回答

    我想實現迭代加深(增量樹構建)。這是我的代碼的一部分,我會問: ExecutorService executorService = Executors.newSingleThreadExecutor(); Set<Callable<Integer>> callables = new HashSet<Callable<Integer>>(); callables.add