在Java中如何实现长时间任务

核心提示：摘要： 在软件开发中，我们经常面临着处理长时间任务的多线程编程问题，在Java中如何实现长时间任务，在我们的ezOne平台的开发中就多处涉及到，如JPC数据服务JPC数据处理服务 报警联动 门禁系统等，你就可以准确的控制任务的执行，例如当JVM通过在java.lang.Runtime.addShutdownHook()

　　摘要： 在软件开发中，我们经常面临着处理长时间任务的多线程编程问题。在我们的ezOne平台的开发中就多处涉及到，如JPC数据服务JPC数据处理服务 报警联动 门禁系统等。本人在编写DEMO程序的过程中几易其稿，煞费心机，但依然感觉有许多地方需要改进，为了减少多线程编程带来的风险，我翻译整理了一个类似问题的解决方案框架以达到一劳永逸。 为了便于阅读，保留原文。引用请保留作者和文章来源。

　　要害词： Thread、 Lock 、 Notification、长时间任务。

　　在应用程序中我们经常需要一个类去完成像数据处理、监听事件或检查另一个类的活动等任务。为了达到这个目标，我们可能使用带有一套锁和消息通知的线程。java 线程API已经很好的文档化，但为了使线程能够正确而高效地运行，程序员仍然需要丰富的编程经验并编写大量的代码。通过应用本篇文章中讨论的框架，程序员能够避免忍受煎熬写大量的代码，快速创建健壮的应用程序。 二、长时间运行任务的程序框架。

　　关于长时间运行的任务的主要事情是如何在应用程序的生命期使它一直保持运行。实现的恰当方法是提供一个线程来执行这个特定的任务。我们可以通过继续Thread类或实现java.lang.Runnable接口来达到该目标。假如采用实现Runnable接口的方式，就可以能够获得更好的面向对象的设计，同时可以避免JAVA中的单继续问题。另外，我们也能更有效的处理Runnable实例（例如使用线程池通常需要一个Runnable实例而不是线程来运行）。

　　框架的基础是一个叫Worker的抽象类，它实现了Runnable接口，并提供了有效处理任务的好方法。这些方法有些已经被实现，如run()方法，但有些是抽象方法，开发人员必须自己来实现。假如要创建一个长时间运行的类，你只需要继续Worker类并实现几个抽象方法。让我们看看这些方法的细节。

　　Worker 类的run()方法被设计成只要不停止运行就持续的执行work()方法。work()方法可以负责数据处理、事件响应、文件读写、，执行SQL命令等操作。这样work()方法能够抛出异常，并将异常传给run()，然后由run()方法来处理这些异常。

　　run()方法有内外两层try-catch语句：一层处于while-loop循环外，一层在while-loop循环内。前一个try-catch用于捕捉非编程异常以确保run()方法不退出。后一个try-catch语句捕捉关于业务逻辑和相应行为的各种异常。假如在work()方法中发生了一些等待操作（例如等待一个输入流或一个Socket），抛出一个InterruptedException的方法是可取的。要记住的是只要应用程序在运行，work()方法不需要任何while-loop循环去维持它运行，这一切由Worker代办了。

　　run()开始时，调用PRepareWorker()方法来预备长时间运行任务需要的所有资源（参考程序清单A）。例如 ，在这个方法中可以打开一个将要用到的数据库连接或文件。尤其对于那些像建立一个socket这样的阻塞操作放在这儿是很好的。因为若让它们在一个独立的线程中运行，则不会阻塞主线程的执行。

　　与前面方法相反的是releaseWorker()，它在run()方法预备退出时被调用（参考程序清单A）。在该方法中你可以编写那些释放系统资源或执行其它清除动作的代码。该方法类似于java.lang.Object.finalize()，但它在线程中止时被显式的调用。

　　三、框架中的错误处理机制

　　另一个重要的方法是handleError()，它带有一个java.lang.Throwable的输入参数。在run()方法每次发生错误时调用这个方法。这依靠于你怎么实现错误处理。方法之一是写错误日志并通过调用halt()方法中止任务（参考程序清单A）。

　　isCondition()方法用于判定work()方法是否能够被执行。因此答应细粒度地控制任务。这在事件触发的框架中非常有用。当work()方法的执行条件未满足时，work方法将被挂起，直到条件完全满足（例如，缓存区非空）。在Worker的实现中这个条件将按在方法setTimeout()中指定的时间周期地检查一个锁通知。假如在任务中不需要任何等待阻塞，仅仅只要使isCondition()方法总是返回真值。

　　四、任务终止时机

　　你还需要isRunning(), broadcast(), halt()方法。通过访问isRunning()方法，你将能检查某个任务是否正在运行，并决定是否中止它。broadcast()方法正确地通知锁对象，并且假如这个对象一直等待这个锁，那么就激活这个任务。halt()方法中止一个任务，因此下一isRunning()状态一旦被调用，run()方法就退出，因为这个方法只通知那个可能阻塞这个任务线程的锁。当在work()方法中执行阻塞作业时用相同的锁是明智的。假如你不能用相同的锁对象时，例如在执行java.io.InputStream.read()方法碰到阻塞时，你就应该添加所有可能锁的显式通知或者增加java.lang.Thread.interrupt()到halt()中。假如一个你阻塞的对象被正确处理，java.lang.Thread.interrupt()将会起作用。例如，它在InputStream.read()执行时有作用，但在执行java.sql.PreparedStatement.execute()不起作用，因此在每个非凡的条件下你必须测试halt()方法。

　　一旦你熟悉Worker类，你就很轻易创建你自己的实现（参考程序清单B），为了把这类当作一个线程运行，仅仅只需简单地使用 new Thread(new WaitedWorker()).start。应用Thread.interrupt()或Worker.halt()或它们的组合，你就可以准确的控制任务的执行。例如当JVM通过在java.lang.Runtime.addShutdownHook()方法中放相应的代码停止时，你就能停止所有的任务。