实战java Concurrent

bsp;     executorService.shutdown();          }      }        /**      * 关闭当前ExecutorService，随后根据poolSize创建新的ExecutorService      */      public void createExecutorService() {          destoryExecutorService(1000);          executorService = Executors.newFixedThreadPool(poolSize);      }        /**      * 调整线程池大小      * @see #createExecutorService()      */      public void setPoolSize(int poolSize) {          this.poolSize = poolSize;          createExecutorService();      }  }   　　这里要额外说明一下invokeAll()和invokeAny()方法。前者会执行给定的所有Callable<T>对象，等所有任务完成后返回一个包含了执行结果的List<Future<T>>，每个Future.isDone()都是true，可以用Future.get()拿到结果；后者只要完成了列表中的任意一个任务就立刻返回，返回值就是执行结果。　　还有一个比较诡异的地方　　本代码是在JDK 1.6下编译测试的，如果在JDK 1.5下测试，很可能在invokeAll和invokeAny的地方出错。明明ValidationTask实现了 Callable<Node>，可是它死活不认，类型不匹配，这时可以将参数声明由List<ValidationTask>改为 List<Callable<Node>>。造成这个问题的主要原因是两个版本中invokeAll和invokeAny的方法签名不同，1.6里是invokeAll(Collection<? extends Callable<T>> tasks)，而1.5里是invokeAll(Collection<Callable<T>> tasks)。网上也有人遇到类似的问题(invokeAll() is not willing to acept a Collection<Callable<T>> )。 　　和其他资源一样，线程池在使用完毕后也需要释放，用shutdown()方法可以关闭线程池，如果当时池里还有没有被执行的任务，它会等待任务执行完毕，在等待期间试图进入线程池的任务将被拒绝。也可以用shutdownNow()来关闭线程池，它会立刻关闭线程池，没有执行的任务作为返回值返回。 2、Lock　　多线程编程中常常要锁定某个对象，之前会用synchronized来实现，现在又多了另一种选择，那就是java.util.concurrent.locks。通过Lock能够实现更灵活的锁定机制，它还提供了很多synchronized所没有的功能，例如尝试获得锁(tryLock())。 使用Lock时需要自己获得锁并在使用后手动释放，这一点与synchronized有所不同，所以通常Lock的使用方式是这样的：Java代码  Lock l = ...;   l.lock();  try {      // 执行操作  } finally {      l.unlock();  }   java.util.concurrent.locks中提供了几个Lock接口的实现类，比较常用的应该是ReentrantLock。以下范例中使用了ReentrantLock进行节点锁定：Java代码  package service;    import java.util.concurrent.locks.Lock;  import java.util.concurrent.locks.ReentrantLock;    /**  * 节点类  *   * @author DigitalSonic  */  public class Node {      private String name;