callable

    9熱度

    4回答

    對於執行者服務我很新穎。我喜歡自己做所有事情,但我認爲是時候信任這些服務了。 我想交由Executer a Runnable。執行者用FutureTask將其包裹並將其交還給我。現在我打電話詢問done()方法。但是,如果done()方法返回true,我希望得到通知。 有一個get()方法阻止,直到Runnable完成,但然後我需要一個額外的線程爲每個工作,只是爲了看看它什麼時候結束。 我可以讓我

    3熱度

    2回答

    我正在接收一個程序,該程序接收主題的搜索請求,使API調用紐約時報API來獲取與該主題相關的文章,然後到Twitter API獲取提及文章的推文,並最終處理結果並將其返回。 我必須使這個多線程。我想過使用帶有固定大小線程池的ExecutorService。所以,每個傳入的搜索請求將由一個單獨的線程處理。我也使用Callable接口來提交任務。實現Callable的類執行API處理(使&接收API請

    1熱度

    1回答

    我正在將實現添加到更大項目(HypergraphDB)中的某些子系統,並且我應該避免修改重要的代碼。在這個項目中,大約有70個Callable對象爲一些數據庫操作定義事務塊。在定義事務塊之前,我正在替換該數據庫,並且我的(redis)需要所有受影響的密鑰。所以我需要訪問這些Callables中的部分,並在執行call()之前執行一些操作(「監視」)。 一些可加密元素是非平凡的,對於其中一些我需要聲

    4熱度

    1回答

    我剛開始玩弄的Symfony 2.0,並立即遇到了一個錯誤: [28-Nov-2011 16:51:26] PHP Fatal error: Uncaught exception 'InvalidArgumentException' with message 'A callable is expected in AnnotationRegistry::registerLoader().' 進一步挖

    2熱度

    1回答

    我這個簡單的代碼: @Override public Object call() throws Exception { try (Connection conn = ConnectionPool.getConnection()) { pageDAO = new PageDAO(conn); linkDAO = new LinkDAO(conn); l

    3熱度

    3回答

    我想控制每個線程使用的時間量。 一個線程執行一些處理,另一個線程處理數據庫中的數據,但由於生成的數據量太大,插入比處理慢。我想給更多的處理器時間來插入數據。 是否有可能用線程做到這一點?目前,我正在進行處理的線程中休眠,但插入的時間根據機器而改變。有另一種方法可以做到這一點嗎?涉及到在我的程序中使用線程同步的方式?

    3熱度

    2回答

    我們使用callable<V>和Future<V>來接收線程池中已終止線程的結果。我們應該致電get()接收返回的結果。我的問題是:它不是事件驅動的。有沒有任何框架可以獲得結果,例如SIGCHLD用於C中的子進程? 我想是這樣的:(線程池將調用這個函數時在池中的每個線程完成了工作) public void fetchResult(Thread t, Runnable r, Future<Integ

    1熱度

    2回答

    我對ExecutorService不熟悉,但不確定我的方法。 我可以爲一個已知的任務處理多達100個線程。 我使用下面的一般格式,在那裏創建FutureTasks列表,然後將它們提交給ExecutorService。 ExecutorService返回並將這些掛起的結果添加到另一個列表。 然後我遍歷這個列表,每個掛起的結果調用get()。 我的查詢是:將不會在每個get()上的這個塊,直到所有10

    1熱度

    2回答

    我一直在使用Callable,但現在我需要函數在call方法中使用參數。我知道這不是call的能力,所以我該如何做到這一點? 我目前有(錯誤): AsyncTask async = new MyAsyncTask(); async.finished(new Callable(param) { // the function called during async.onPostExecu

    1熱度

    4回答

    我想在同一時間啓動多個可調用線程(在循環中),並且想要返回主線程中每個人的一些信息。如何實現這一點?