创建一个线程有几种方式，很容易想到的就是集成Thread类，实现Runnable接口，还有一种方式就是自己定义的线程类实现Callable接口，这种方式相较于实现Runnable接口具有带有返回值的特点，大家都知道在java中主线程中创建的线程可以独立于主线程执行，也就是说main函数结束了。在main函数中产生的线程还在继续执行，如果希望主线程在所有子线程都结束再结束，该怎么做呢？可以试想这样一种场景：创建了50个线程，每个线程计算10000个数字之和，最后计算出总和。如果线程继承了Runnable接口，每个线程就无法把结果返回，或许回想到使用全局变量，每个线程对全局进行操作，并通过锁机制控制线程安全。这种方式还需要考虑一个问题就是，最后的结果怎么输出？可以在主线程输出嘛~，但是此时就涉及到主线程等待子线程的问题了？但是使用实现了Callable接口的线程类，就可以很优美的解决以上问题，让每个线程类计算自己负责的部分，然后得出自己的结果，刚才又说，实现了Callable接口的线程可以返回结果，这样我们就可以在主线程中将结果取出，此时取出结果的方法是个阻塞的方法，也就是该子线程如果没有获得结果会一直等待在那，这样我们把每个线程的值取出后在主线程中计算出总和，最后输出，这样简单明了。下面一个简单的例子可以看出Callable如何使用，Callable还有其他特点，有兴趣可以自行查阅。

/** Callable接口支持泛型，此处设置返回值类型为String*/

public class ClientThread implements Callable<String>{

/** 实现Runnable要复写run方法，但实现Callable接口需要复写call方法*/
@Override
public String call() {
　　/** 此处写你的逻辑处理*/

　　StringBuilder builder = new StringBuilder();

　　for(int i = 0; i < 4; i++)

　　{

　　　　builder.append((int)(Math.random()*10 + 1));　　//产生1~9的随机数；

　　}

　　return builder.toString();
}

 

public Class Test{　　

　　public static void main(String[] args)
　　{
　　　　log.info("客户端启动...");
　　　　getGoodsId();
　　　　List<Future<String>> list = new ArrayList<Future<String>>();　　//Future<String>是线程执行
　　　　ExecutorService pool = Executors.newFixedThreadPool(10);　　//线程池，产生10个线程备用
　　　　for(int i = 0; i < 10; i++)
　　　　{
　　　　　　ClientThread ct = new ClientThread();
　　　　　　list.add(pool.submit(ct));
　　　　}
　　　　for(Future<String> f : list)
　　　　{
　　　　　　try {

　　　　　　　　　　/** 该方法让主线程阻塞，等待子线程返回结果*/
　　　　　　　　　　System.out.println(f.get());　
　　　　　　  　} catch (InterruptedException | ExecutionException e) {
　　　　　　　　　　log.error("在将线程结果带出时出错");
　　　　　　　  }
　　　　}
　　　　pool.shutdownNow();
　　}

}

关于线程池的使用方式不了解的可以百度一下。