Java中的Callable实现多线程详解

@FunctionalInterface
public interface Callable<V>{
    public V call() throws Exception;
}

class MyThread4 implements Callable<String>{ // 定义核心业务类
	private String name;
	public MyThread4(String name) {
		this.name = name;
	}
	@Override
	public String call() throws Exception {
		for(int i = 0 ; i < 100; i++) {
			System.out.println(this.name + "线程运行， x = " + i);
		}
		return "执行完毕";  // 返回值
	}
}

public interface Future<V>{
    V get() throws InterruptedException, ExecutionException;
}

public interface RunnableFuture<V>
extends Runnable, Future<V>{
    void run();
}

public FutureTask(Callable<V> callable)

class MyThread4 implements Callable<String>{ // 定义核心业务类
	private String name;
	public MyThread4(String name) {
		this.name = name;
	}
	@Override
	public String call() throws Exception {
		for(int i = 0 ; i < 100; i++) {
			System.out.println(this.name + "线程运行， x = " + i);
		}
		return "执行完毕";  // 返回值
	}
}
public class CallableTest {
	public static void main(String[] args) throws Exception{
		Callable<String> callA = new MyThread4("线程A");
		Callable<String> callB = new MyThread4("线程B");
		Callable<String> callC = new MyThread4("线程C");
		FutureTask<String> futureA = new FutureTask<String>(callA);
		FutureTask<String> futureB = new FutureTask<String>(callB);
		FutureTask<String> futureC = new FutureTask<String>(callC);
		new Thread(futureA).start();
		new Thread(futureB).start();
		new Thread(futureC).start();
		System.out.println("A执行返回结果："  + futureA.get());
		System.out.println("B执行返回结果："  + futureB.get());
		System.out.println("C执行返回结果："  + futureC.get());
	}
}