Java后台线程

Question

我想知道如何最好地实现背景来执行一些任务。根据任务中的一些条件，它将结束并返回一个状态的调用者。此外，当后台线程正在运行时，它不应阻止调用者线程等待其完成。我已经尝试过FutureTask，但它同步完成所有事情。

请怪人帮我。

Answer 1

正如@格雷所建议的，做研究可能是最好的选择。看看The Fork/Join Framework或some other Executor Services。如果不了解更多关于你在做什么的事情，很难就什么是合适的提供更好的建议。

This也给出了一些从哪里开始的例子。

Answer 2

可以使用执行人（由于Java 1.5） http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/Executors.html

Executor executor= Executors.newSingleThreadExecutor(); 
Future<ReturnType> future = executor.sumbit(new MyCallable<ReturnType>()); 

// new thread running... 
// ....... 

// synchronize/join..... 
executor.shutdown(); 
executor.awaitTermination(30, TimeUnit.MINUTES); 

// also you can do... (Get --> Waits if necessary for the computation to complete, and then retrieves its result.) 
ReturnType myreturn = future.get(); 

Answer 3

这里是一个非常简单的两线的例子。你应该可以修改它来完成你需要的任何事情。我会使用队列来返回你的结果。看看消费者poll是如何排队的，你可以在主线程中做到这一点，以等待线程的结果。

public class TwoThreads { 
    public static void main(String args[]) throws InterruptedException { 
    System.out.println("TwoThreads:Test"); 
    new Test().test(); 
    } 
    // The end of the list. 
    private static final Integer End = -1; 

    static class Producer implements Runnable { 
    final Queue<Integer> queue; 
    private int i = 0; 

    public Producer(Queue<Integer> queue) { 
     this.queue = queue; 
    } 

    @Override 
    public void run() { 
     try { 
     for (int i = 0; i < 1000; i++) { 
      queue.add(i++); 
      Thread.sleep(1); 
     } 
     // Finish the queue. 
     queue.add(End); 
     } catch (InterruptedException ex) { 
     // Just exit. 
     } 
    } 
    } 

    static class Consumer implements Runnable { 
    final Queue<Integer> queue; 
    private int i = 0; 

    public Consumer(Queue<Integer> queue) { 
     this.queue = queue; 
    } 

    @Override 
    public void run() { 
     boolean ended = false; 
     while (!ended) { 
     Integer i = queue.poll(); 
     if (i != null) { 
      ended = i == End; 
      System.out.println(i); 
     } 
     } 
    } 
    } 

    public void test() throws InterruptedException { 
    Queue queue = new LinkedBlockingQueue(); 
    Thread pt = new Thread(new Producer(queue)); 
    Thread ct = new Thread(new Consumer(queue)); 
    // Start it all going. 
    pt.start(); 
    ct.start(); 
    // Wait for it to finish. 
    pt.join(); 
    ct.join(); 
    } 
}