java.util.concurrent包开发实例

从JDK5.0开始，JDK中加入了并发包，最近刚开始使用。感觉对于应用开发非常方便。在开发过程中，我自己碰到两种情况的应用场景。就从应用场景来分析concurrent包的应用。

场景一：任务的定时、延时执行。比如指定某个状态检查的任务程序定时执行。

场景二：有多任务同时提交，而且这些任务相互独立。这些任务可以并行执行的，但是，各个任务最终需要返回执行的结果。

场景一是非常常见的，当然也已经有很多成熟的机制来实现它，比如：定时器Timer。在并发包中接口java.util.concurrent.

ScheduledExecutorService可以非常轻松地完成定时，延时执行，同时可以返回执行结果。通过ScheduledFuture接口跟踪任务执行情况，并获取执行结果。
例如：如下代码：

import static java.util.concurrent.TimeUnit.*;
class BeeperControl {
    private final ScheduledExecutorService scheduler =
       Executors.newScheduledThreadPool(1);

    public void beepForAnHour() {
        final Runnable beeper = new Runnable() {
                public void run() { System.out.println("beep"); }
            };
        final ScheduledFuture<?> beeperHandle =
            scheduler.scheduleAtFixedRate(beeper, 10, 10, SECONDS);
        scheduler.schedule(new Runnable() {
                public void run() { beeperHandle.cancel(true); }
            }, 60 * 60, SECONDS);
    }
}
场景二中，对于并发执行其实并不难，但是如果说要得到执行结果，就比较复杂，主要困难在于任务执行完之后如何获取执行结果，所有任务执行结束之后，如何提醒父进程。在并发实用包中提供的ExecutorService 接口来发起任务，及得到跟踪任务的执行状况的Future的方法。

实例代码如下：

class App {
   ExecutorService executor = ...
   ArchiveSearcher searcher = ...
   void showSearch(final String target) throws InterruptedException {
     Future<String> future = executor.submit(new Callable<String>() {
         public String call() { return searcher.search(target); }
     });
     displayOtherThings(); // do other things while searching
     try {
       displayText(future.get()); // use future
     } catch (ExecutionException ex) { cleanup(); return; }
   }
}
这里实现的Future对象，在取结果的时候是阻塞的，直到该项任务返回结果。因此只要对获取的future对象做操作，即可以控制程序的执行顺序。

最后写一些想法：其实并发程序在很多时候能够极大地加快执行的效率，现在比较流行的多机器联合工作，其实完全可以用这套并行机制来实现。分服务器和任务机，服务器负责分解任务，任务机负责执行任务并返回结果，服务器负责收集结果并且整合。对于简单模型的可拆解任务，完全可以实现。对于复杂的如：多个结果间具有顺序关系，结果相互影响等就比较麻烦。

标题不错，只是没说什么实质内容。

你的两个场景并不是Concurrent最合适的用武之地，完全是异步处理和回调所做的事情。

标题不错，只是没说什么实质内容。

只是工作中遇到的两个场景。
但是我认为，第二个场景是concurrent包的核心功能，多任务的并发，并且结果返回。

fork-join....

标题党，看似有点内容，进来却东拉西扯的，不全面不系统，能不能研究透了再写啊

为什么要beeperHandle.cancel(true);

现在的电信企业应用中，多数接口都是第二种情况。