Java多线程编程模式实战指南：Two-phase Termination模式

2024-09-07 00:48
文章标签 java 实战 模式 多线程 编程 指南 two phase termination

本文主要是介绍Java多线程编程模式实战指南：Two-phase Termination模式，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章来源：

http://www.infoq.com/cn/articles/java-multithreaded-programming-mode-two-phase-termination?utm_source=infoq&utm_campaign=user_page&utm_medium=link

文章代码地址：

https://github.com/Viscent/JavaConcurrencyPattern/

停止线程是一个目标简单而实现却不那么简单的任务。首先，Java没有提供直接的API用于停止线程。此外，停止线程时还有一些额外的细节需要考虑，如待停止的线程处于阻塞（等待锁）或者等待状态（等待其它线程）、尚有未处理完的任务等。本文介绍的Two-phase Termination模式提供了一种通用的用于优雅地停止线程的方法。

一、Two-phase Termination模式简介

Java并没有提供直接的API用于停止线程。Two-phase Termination模式通过将停止线程这个动作分解为准备阶段和执行阶段这两个阶段，以应对停止线程过程中可能存在的问题。

准备阶段。该阶段主要动作是“通知”目标线程（欲停止的线程）准备进行停止。这一步会设置一个标志变量用于指示目标线程可以准备停止了。但是，由于目标线程可能正处于阻塞状态（等待锁的获得）、等待状态（如调用Object.wait）或者I/O（如InputStream.read）等待等状态，即便设置了这个标志，目标线程也无法立即“看到”这个标志而做出相应动作。因此，这一阶段还需要通过调用目标线程的interrupt方法，以期望目标线程能够通过捕获相关的异常侦测到该方法调用，从而中断其阻塞状态、等待状态。对于能够对interrupt方法调用作出响应的方法（参见表1），目标线程代码可以通过捕获这些方法抛出的InterruptedException来侦测线程停止信号。但也有一些方法（如InputStream.read）并不对interrupt调用作出响应，此时需要我们手工处理，如同步的Socket I/O操作中通过关闭socket，使处于I/O等待的socket抛出java.net.SocketException。

这里写图片描述
表 1. 能够对Thread.interrupt作出响应的一些方法

执行阶段。该阶段的主要动作是检查准备阶段所设置的线程停止标志和信号，在此基础上决定线程停止的时机，并进行适当的“清理”操作。清理操作很重要，否则会引起内存溢出或者泄露等等难以排查的问题。

二、Two-phase Termination模式的架构

Two-phase Termination模式的主要参与者有以下几种。其类图如图1所示。

这里写图片描述
图 1. Two-phase Termination模式的类图

  • ThreadOwner：目标线程的拥有者。Java语言中，并没有线程的拥有者的概念，但是线程的背后是其要处理的任务或者其所提供的服务，因此我们不能在不清楚某个线程具体是做什么的情况下贸然将其停止。一般地，我们可以将目标线程的创建者视为该线程的拥有者，并假定其“知道”目标线程的工作内容，可以安全地停止目标线程。

  • TerminatableThread：可停止的线程。其主要方法及职责如下：

    1、terminate：设置线程停止标志，并发送停止“信号”给目标线程。
2、doTerminate：留给子类实现线程停止时所需的一些额外操作，如目标线程代码中包含Socket I/O，子类可以在该方法中关闭Socket以达到快速停止线程，而不会使目标线程等待I/O完成才能侦测到线程停止标记。
3、doRun：留给子类实现线程的处理逻辑。相当于Thread.run，只不过该方法中无需关心停止线程的逻辑，因为这个逻辑已经被封装在TerminatableThread的run方法中了。
4、doCleanup：留给子类实现线程停止后可能需要的一些清理动作。

  • TerminationToken：线程停止标志。toShutdown用于指示目标线程可以停止了。reservations可用于反映目标线程还有多少数量未完成的任务，以支持等目标线程处理完其任务后再行停止。

准备阶段的序列图如图2所示：

这里写图片描述

1、客户端代码调用线程拥有者的shutdown方法。

2、shutdown方法调用目标线程的terminate方法。

3~4、terminate方法将terminationToken的toShutdown标志设置为true。

5、terminate方法调用由TerminatableThread子类实现的doTerminate方法，使得子类可以为停止目标线程做一些其它必要的操作。

6、若terminationToken的reservations属性值为0，则表示目标线程没有未处理完的任务或者ThreadOwner在停止线程时不关心其是否有未处理的任务。此时，terminate方法会调用目标线程的interrupt方法。

7、terminate方法调用结束。

8、shutdown调用返回，此时目标线程可能还仍然在运行。

执行阶段由目标线程的代码去检查terminationToken的toShutdown属性、reservations属性的值，并捕获由interrupt方法调用抛出的相关异常以决定是否停止线程。在线程停止前由TerminatableThread子类实现的doCleanup方法会被调用。

三、Two-phase Termination模式的评价与实现考量

Two-phase Termination模式使得我们可以对各种形式的目标线程进行优雅的停止。如目标线程调用了能够对interrupt方法调用作出响应的阻塞方法、目标线程调用了不能对interrupt方法调用作出响应的阻塞方法、目标线程作为消费者处理其它线程生产的“产品”在其停止前需要处理完现有“产品”等。Two-phase Termination模式实现的线程停止可能出现延迟，即客户端代码调用完ThreadOwner.shutdown后，该线程可能仍在运行。

读者若要自行实现Two-phase Termination模式，可能需要注意以下几个问题。

1、线程停止标志

本文案例使用了TerminationToken作为目标线程可以准备停止的标志。从清单3的代码我们可以看到，TerminationToken使用了toShutdown这个boolean变量作为主要的停止标志，而非使用Thread.isInterrupted()。这是因为，调用目标线程的interrupt方法无法保证目标线程的isInterrupted()方法返回值为true：目标线程可能调用一些能够捕获InterruptedException而不保留线程中断状态的代码。另外，toShutdown这个变量为了保证内存可见性而又能避免使用显式锁的开销，采用了volatile修饰。这点也很重要，笔者曾经见过一些采用boolean变量作为线程停止标志的代码，只是这些变量没有用volatile修饰，对其访问也没有加锁，这就可能无法停止目标线程。

2、生产者——消费者问题中的线程停止

在多线程编程中，许多问题和一些多线程编程模式都可以看作生产者——消费者问题。停止处于生产者——消费者问题中的线程，需要考虑更多的问题：需要注意线程的停止顺序，如果消费者线程比生产者线程先停止则会导致生产者生产的新”产品“无法被处理，而如果先停止生产者线程又可能使消费者线程处于空等待（如生产者消费者采用阻塞队列中转”产品“）。并且，停止消费者线程前是否考虑要等待其处理完所有待处理的任务或者将这些任务做个备份也是个问题。本文案例部分地展示生产者——消费者问题中线程停止的处理，其核心就是通过使用TerminationToken的reservations变量：生产者每”生产“一个产品，Two-phase Termination模式的调用方代码要使reservations变量值增加1（terminationToken.reservations.incrementAndGet()）；消费者线程每处理一个产品，Two-phase Termination模式的调用方代码要使reservations变量值减少1（terminationToken.reservations.decrementAndGet()）。当然，在停止消费者线程时如果我们不关心其待处理的任务，Two-phase Termination模式的调用方代码可以忽略对reservations变量的操作。清单4展示了一个完整的停止生产者——消费者问题中的线程的例子：

清单 4. 停止生产者——消费者问题中的线程的例子

public class ProducerConsumerStop {class SampleConsumer<P> {private final BlockingQueue<P> queue = new LinkedBlockingQueue<P>();private AbstractTerminatableThread workThread = new AbstractTerminatableThread() {@Overrideprotected void doRun() throws Exception {terminationToken.reservations.decrementAndGet();P product = queue.take();// ...System.out.println(product);}};public void placeProduct(P product) {if (workThread.terminationToken.isToShutdown()) {throw new IllegalStateException("Thread shutdown");}try {queue.put(product);workThread.terminationToken.reservations.incrementAndGet();} catch (InterruptedException e) {}}public void shutdown() {workThread.terminate();}public void start() {workThread.start();}}public void test() {final SampleConsumer<String> aConsumer = new SampleConsumer<String>();AbstractTerminatableThread aProducer = new AbstractTerminatableThread() {private int i = 0;@Overrideprotected void doRun() throws Exception {aConsumer.placeProduct(String.valueOf(i));}@Overrideprotected void doCleanup(Exception cause) {// 生产者线程停止完毕后再请求停止消费者线程aConsumer.shutdown();}};aProducer.start();aConsumer.start();}
}

3、隐藏而非暴露可停止的线程

为了保证可停止的线程不被其它代码误停止，一般我们将可停止线程隐藏在线程拥有者背后，而使系统中其它代码无法直接访问该线程，正如本案例代码（见清单1）所展示：AlarmMgr定义了一个private字段alarmSendingThread用于引用告警发送线程（可停止的线程），系统中的其它代码只能通过调用AlarmMgr的shutdown方法来请求该线程停止，而非通过引用该线程对象自身来停止它。

这篇关于Java多线程编程模式实战指南：Two-phase Termination模式的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1143586。

相关文章

网页解析 lxml 库--实战

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库，完全使用 Python 语言编写，它对 XPath表达式提供了良好的支 持，因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块，该模块专门用来解析 HTML/XML 文档，下面来介绍一下 lxml 库
阅读更多...
JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
Java进阶13讲__第12讲_1/2

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory
阅读更多...
性能分析之MySQL索引实战案例

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题，本文将一起从代码层去分析为什么没有建立索引？ 开源ERP项目地址：https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2