并发入门基础(Runnable、Thread、Executor).docxVIP

HYPERLINK /hzmark/archive/2013/01/21/ConcurrentBase.html 并发基础（Runnable、Thread、Executor） ? ? ?与顺序编程不同，并发使程序可以在“同一时间”执行多个操作。 ? ? ?Java对并发编程提供了语言级别的支持。Java通过线程来实现并发程序。一个线程通常实现一个特定的任务，多个线程一起执行的时候就实现了并发。 ? ? ?定义任务的最简单的方式就是实现Runnable接口。 1 public interface Runnable { 2 public abstract void run(); 3 } ? ? ?Runable只定义了一个run()方法。 ? ? ?下面是一个监听用户输入的任务。 1 public class Monitor implements Runnable { 2 3 @Override 4 public void run() { 5 BufferedReader reader = new BufferedReader(new InputStreamReader( 6 System.in)); 7 while (true) { 8 String str; 9 try { 10 str = reader.readLine(); 11 if (str.equals(quit)) { 12 return; 13 } else { 14 System.out.println(str); 15 } 16 } catch (IOException e) { 17 e.printStackTrace(); 18 } 19 20 } 21 } 22 } ? ? ?执行一个任务最简单的方式是把它交给一个Thread构造器。 1 public class Test { 2 public static void main(String[] args) { 3 System.out.println(Main Start); 4 Thread task = new Thread(new Monitor()); 5 task.start(); 6 System.out.println(Main End); 7 } 8 } ? ? ?执行上面的程序可以看到类似下面这样的结果： ? ? ? ? ? ?可以看到Main方法一次执行各语句到最后输出“Main End”，但Monitor依旧在运行，因为它在另一个线程中。 ? ? ?除了Thread的方式，Java还提供了执行器Executor简化并发编程。 ? ? ?Executor使用execute(Runnable command)方法执行一个任务，使用shutdown()方法防止新任务被提交给Executor，当前线程将继续执行shutdown()方法调用之前提交的任务。像这样： 1 public static void main(String[] args) { 2 System.out.println(Use Executor...); 3 ExecutorService exec = Executors.newCachedThreadPool(); 4 exec.execute(new Monitor()); 5 exec.shutdown(); 6 } ? ? ?Executor的详细内容见 HYPERLINK /hzmark/archive/2013/01/21/JavaExecutor.html 《Java Executor框架分析》。 ? ? ? ?Runnable只是执行一个任务，但是并不能获取任务的执行结果（准确的说应该是run方法是一个void的方法，没有返回值）。如果希望获取任务的执行结果，那么可以选择实现Callable接口。 1 public interface CallableV { 2 V call() throws Exception; 3 } ? ? ?它是一个接收泛型，且具有返回内容的