/* * 实现java.util.concurrent.Callable接口的类,可以被线程执行,并且还可以返回值 * 返回String */ public class Demo_04ThreadCallable implements Callable<String> { public String call() { System.out.println("实现Callable接口的线程实现"); return "abc"; } } public class Demo_02Runnable implements Runnable { public void run() { System.out.println(Thread.currentThread().getName() + " 线程池"); } } public class Demo_03Thread { public static void main(String[] args) throws Exception { ExecutorService service = Executors.newFixedThreadPool(2); // 提交线程,实现Callable接口实现类对象, submit返回 Future接口的实现类对象 Future<String> f = service.submit(newDemo_04ThreadCallable()); // 调用Future接口的实现类对象方法 get String s = f.get(); System.out.println(s); // submit可以提交Runnable接口的实现类,获取返回值,但是, run方法,void Future f1 = service.submit(new Runnable() { public void run() { } }); System.out.println(f1.get()); } } |