是Callable接口的一個線程？我無法運行任何東西，但它工作

Question

我一直在爲一個簡單的迷宮項目工作了一段時間，我到了需要使用Callable接口作爲線程的地步。在實現和運行後，我注意到，雖然可調用類在後臺運行，但我似乎無法在後臺運行其他任何操作，例如輸入。

我做了一個小項目強調問題，看到，雖然可調用類工作10秒，但我不能在任何輸入的同時。 這裏是代碼：

主要類

public class Main { 

    static ExecutorService service = null; 
    static Future<String> task = null; 

    public static void main(final String[] argv) throws IOException { 
     BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); 
     System.out.println("please enter a command"); 
     String string = in.readLine(); 
     while (!string.equals("exit")) { 
      if (!string.equals("command")) { 
       System.out.println("command not found"); 
      } else { 
       service = Executors.newFixedThreadPool(1); 
       task = service.submit(new Foo()); 

       try { 
        final String str; 

        // waits the 10 seconds for the Callable.call to finish. 
        str = task.get(); // this raises ExecutionException if 
             // thread dies 
        System.out.println(str); 
        service.shutdownNow(); 
       } catch (final InterruptedException ex) { 
        ex.printStackTrace(); 
       } catch (final ExecutionException ex) { 
        ex.printStackTrace(); 
       } 
      } 
      string = in.readLine(); 

     } 

     // 
    } 
} 

可調用的類：

class Foo implements Callable<String> { 
    @Override 
    public String call() { 
     try { 
      // sleep for 10 seconds 
      Thread.sleep(10 * 1000); 
     } catch (final InterruptedException ex) { 
      ex.printStackTrace(); 
     } 

     return ("Hello, World!"); 
    } 
} 

Answer 1

問題是str = task.get();。

按照JavaDoc，以瞭解未來＃get（）方法（https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html#get%28%29）：

如有必要，等待計算完成，然後獲取其結果。

如果您想要Callable的結果，則必須等到結束。

Answer 2

可贖回並不在其本身做任何事情。這只是一個約定界面。爲了使可調用的異步，你需要在執行器中運行它。例如見https://blogs.oracle.com/CoreJavaTechTips/entry/get_netbeans_6。

Answer 3

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#submit(java.util.concurrent.Callable)

如果您想立即阻塞任務的等待，你可以使用表格結果= exec.submit（aCallable）。獲得的結構（）;

這是你在做什麼（阻塞主線程等待一個任務）

Answer 4

我注意到，雖然可調用類在後臺運行，我似乎無法工作，什麼都在後臺

......討論......問題解釋...

現在使用這個界面似乎毫無意義。

我真的不知道你想幹什麼，但ExecutorService和Callable整個點是在後臺執行任務。

但是「在後臺」是什麼意思？這意味着，當新線程關閉執行一些任務時，提交任務的線程可以執行其他操作。

它看起來像這樣：

final ExecutorService executorService = Executors.newFixedThreadPool(NUM_THREADS); 

ReturnType doSomethingInTheBackground() { 

    // create the task object 
    Callable<ReturnType> task =() -> doSomething(); 

    // submit the task object 
    Future<ReturnType> future = executorService.submit(task); 

    doSomethingElse(); 

    // wait for the result. 
    return future.get(); 
} 

private ReturnType doSomething() { ... } 

private void doSomethingElse() { ... } 

的doSomethingElse()電話是什麼讓一切都值得。如果調用線程除了等待結果（即調用future.get()）之外沒有別的事情要做，那麼你是對的：使用多個線程沒有意義。調用線程只需要執行任務就簡單了。