`
阿男bluedash
  • 浏览: 168801 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Java中的多线程竞争与CountDownLatch的应用

    博客分类:
  • Java
阅读更多


线程间的竞争叫做Racing,正如这篇文章的图片一样,不同的线程好比在高速赛道上行驶的F1方程式赛车,当赛车在各自的赛道上互不影响各自行驶时,可以相安无事。但这是一场比赛,既然是比赛,必然有并线、超车的行为,此时两辆赛车很可能会挤到赛道中公共的部分,如果此时两车速度相差不多,而且距离差距不大,就极有可能发生可怕的事故。

在计算机世界里,不同的线程运行的程序就好比不同赛道上的赛车。如果各个线程相互独立,完全没有关系,不会相互影响。但实际情况往往没有这么简单,线程可能会共同访问某个共享资源,并操作这些共享资源,如果程序逻辑依赖于这些资源,那么不同线程执行的先后次序就很有可能会影响到程序的执行结果。如果我们不对线程间的访问加以协调和控制,就可能导致错误的输出。

下面这个例子里,我想展示一下线程竞争的情况:

package net.bluedash.countdownlatch;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class SampleServerWithRacingProblem {

	private boolean running = true;

	private ServerSocket socket;

	public SampleServerWithRacingProblem() throws IOException {
		init();
	}

	private void init() throws IOException {
		socket = new ServerSocket(8080);
	}

	public void accept() {
		while (running) {
			try {
				Socket connection = socket.accept();
				connection.getOutputStream().write(". ".getBytes());
				connection.getOutputStream().flush();
				connection.close();
			} catch (IOException e) {
				System.out.print("\nC");
				return;
			}
		}
		System.out.print("\nG");
	}

	public void close() throws IOException, InterruptedException {
		running = false;
		socket.close();

}


上面的这段代码是一个基础的Socket服务端。这个类侦听8080端口,并通过accept()方法来接收客户端的请求,当客户端有连接时,返回给客户端一个"."的字符。此外,这个类中还包含一个close()方法,用于结束服务。整个代码最关键的就是running这个变量,通过设置running为true,服务器保持接受请求进行服务,如果服务被 close掉,running就被置为false ,此时客户端如果有请求,服务器就会输出一个"G",表示服务已关闭。如果在running的过程中出现Exception,则像屏幕输出一个"C",并直接返回。

一切看起来都完美无缺,但真的如此吗?我们来写一个测试程序来使用这段代码,看看它是否像我们期望的那样工作。首先我们撰写一个线程类,用于启动上面的服务端代码:

package net.bluedash.countdownlatch;

public class ServerWorker implements Runnable {

	private SampleServerWithRacingProblem server;

	public ServerWorker(SampleServerWithRacingProblem server) {
		this.server = server;

	}

	@Override
	public void run() {
		System.out.print("A");
		server.accept();
	}

}


这段代码的作用是把服务端的代码封装进一个Thread,让服务端在独立的线程中运行,防止我们要撰写的主程序被服务端的accept()给block住。并向屏幕输出一个"A"表示服务启动。

接下来我们撰写客户端程序,让客户端连接至8080端口,持续不断地访问服务端,并向屏幕打印服务端的返回数据:

package net.bluedash.countdownlatch;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;

public class ClientWorker implements Runnable {

	@Override
	public void run() {
		try {
			while (true) {
				Thread.sleep(100); // 防止客户端请求太快,消耗大量系统资源
				Socket socket = new Socket("127.0.0.1", 8080);
				BufferedReader rd = new BufferedReader(new InputStreamReader(
						socket.getInputStream()));
				String line;
				while ((line = rd.readLine()) != null) {
					System.out.print(line);
				}
				socket.close();
			}
		} catch (Exception ignore) {
		}
	}

}


最后是主程序:

package net.bluedash.countdownlatch;

import java.io.IOException;

public class UseSampleServer {

	public static void main(String[] args) throws IOException,
			InterruptedException {
		SampleServerWithRacingProblem server = new SampleServerWithRacingProblem();
		ServerWorker serverWorker = new ServerWorker(server);

		Thread serverThread = new Thread(serverWorker);
		serverThread.start();

		// 开启5个客户端连接
		for (int i = 0; i < 5; i++) {
			ClientWorker clientWorker = new ClientWorker();
			Thread clientThread = new Thread(clientWorker);
			clientThread.start();
		}

		// 给客户端时间5秒钟时间去跑起来,防止服务器过早地关闭
		Thread.currentThread().sleep(5000);
		
		server.close();
		System.out.print("\nQ");
	}
}


把主程序跑起来,我们得到的结果如下:

A. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 
Q
C


出乎意科的事情发生了,主程序执行了server.close();后,服务端程序没有正确地退出,而是在accept()方法里抛出了异常,打印出了C的结果,而不是期望中的G。这是为什么呢?其实原因出在running这个变量上。当主程序发送了server.close();的请求后,running被置为false, 但客户端的速度也是很快的,此时可能已经发起请求,并已经由服务端进行服务。但服务端此时恰好已经关闭了socket,因此在服务端的主程序中抛出了异常IOException, 并打印了字符 C。

这就是一个典型的线程竞争的场景,该如何解决这个问题呢?其实我们的逻辑没有错,只不过在上面的代码里,对running的写操作和判断running的状态没有协调好。我们的代码应该保证在running设置为false后,所有当前在跑的客户端程序都结束后,再关闭socket。 通过使用import java.util.concurrent.CountDownLatch, 我们便可以实现这一点:

package net.bluedash.countdownlatch;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.CountDownLatch;

public class SampleServerWithoutRacingProblem {

	private boolean running = true;

	private ServerSocket socket;

	private CountDownLatch lock = new CountDownLatch(1);

	public SampleServerWithoutRacingProblem() throws IOException {
		init();
	}

	private void init() throws IOException {
		socket = new ServerSocket(8080);
	}

	public void accept() {
		while (running) {
			try {
				Socket connection = socket.accept();
				connection.getOutputStream().write(". ".getBytes());
				connection.getOutputStream().flush();
				connection.close();
			} catch (IOException e) {
				System.out.print("\nC");
				return;
			}
		}
		lock.countDown();
		System.out.print("\nG");
	}

	public void close() throws IOException, InterruptedException {
		running = false;
		lock.await();
		socket.close();
	}

}


如上面的代码所示,我们首先创建了一个计数锁:

private CountDownLatch lock = new CountDownLatch(1);


在accept方法里面,我们在running被置为false后,将锁释放掉:

lock.countDown();


然后在close方法里,等待这个锁释放后,才可以将socket关闭:

public void close() throws IOException, InterruptedException {
	running = false;
	lock.await();
	socket.close();
}


注意上面代码中的逻辑顺序,首先将running置为false,然后等待accept方法中逻辑执行完后将锁释放掉,然后才可以继续向下执行socket.close()方法关闭连接。如果accept方法没有释放锁,close方法中的lock.await()将一直处于等待状态,从而避免过早关闭socket。

重新运行测试代码,程序输出如下:

A. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 
G
Q. 


可以看到,程序已经按照我们预期来工作。

我将上面用到的例子放在了github上面,有兴趣可以下载下来玩玩看:

git clone git://github.com/liweinan/try-countdownlatch.git


下载完成后,首先需要编译代码:
mvn install


然后可运行maven命令运行例子:

mvn exec:java -Dexec.mainClass="net.bluedash.countdownlatch.UseSampleServer" -Dexec.args='WithProblem'


上面的命令将会使用SampleServerWithRacingProblem产生线程竞争的结果。下面的例子则使用SampleServerWithoutRacingProblem,由于锁的保护,不会产生竞争:

mvn exec:java -Dexec.mainClass="net.bluedash.countdownlatch.UseSampleServer" -Dexec.args='WithoutProblem'

  • 大小: 70.4 KB
分享到:
评论
1 楼 cfyme 2012-09-21  
学习了,写得很好

相关推荐

    JAVAJAVA多线程教学演示系统论文

    《JAVA多线程教学演示系统》是一篇深入探讨JAVA多线程编程的论文,它针对教育领域中的教学需求,提供了一种生动、直观的演示方式,帮助学生更好地理解和掌握多线程技术。这篇论文的核心内容可能包括以下几个方面: ...

    java多线程进度条

    本主题将深入探讨如何在Java多线程环境下实现进度条功能。 首先,理解Java多线程的基本概念至关重要。Java通过Thread类和Runnable接口来支持多线程。创建一个新线程通常有两种方式:继承Thread类并重写run()方法,...

    Java多线程编程实战指南-核心篇

    《Java多线程编程实战指南-核心篇》是一本深入探讨Java并发编程的书籍,旨在帮助读者掌握在Java环境中创建、管理和同步线程的核心技术。Java的多线程能力是其强大之处,使得开发者能够在同一时间执行多个任务,提高...

    经典Java多线程与并发库高级应用

    在深入探讨Java多线程与并发库的高级应用前,有必要了解一些基础概念。Java线程是Java程序的基础,它代表程序中的一条执行线索或线路。在Java中创建线程有两种传统方式,一种是通过继承Thread类并覆盖其run方法来...

    Java多线程编程

    Java多线程编程是Java开发中的重要组成部分,它允许程序同时执行多个任务,极大地提高了程序的效率和响应性。在Java中,多线程主要通过`Thread`类和并发工具来实现,接下来我们将深入探讨这些关键知识点。 1. **...

    java中的多线程实例详解(自己去运行看结果)

    本文将深入探讨Java多线程的实例,帮助读者理解其工作原理和实际应用。 首先,我们需要了解线程的基本概念。在Java中,线程是程序的单一顺序控制流,每个线程都有自己的程序计数器、虚拟机栈、本地方法栈和一部分堆...

    java多线程编程

    Java多线程编程是Java开发中的重要组成部分,它允许程序同时执行多个任务,提升系统效率。在本教程中,我们将深入探讨Java中的多线程设计模式、并发核心编程概念以及线程池的工作原理和种类。 首先,让我们了解什么...

    java多线程示例

    在Java编程语言中,多线程是核心特性之一,它允许程序同时执行多个任务,从而提高了应用程序的效率和响应...文档“java多线程实例.docx”可能包含具体的示例代码和详细解释,建议参考学习,以加深对Java多线程的理解。

    深入学习:Java多线程编程

    Java多线程是Java编程中的核心部分,尤其在现代高性能应用和分布式系统中不可或缺。理解并掌握Java多线程能够提升程序的效率、响应速度以及资源利用率。 本书可能涵盖了以下几个重要的知识点: 1. **线程基础**:...

    java多线程编程实例_Source

    在本实例源码中,包含17个章节和上百个实例,旨在深入讲解Java多线程的核心概念和实际应用。 一、线程基础知识 在Java中,线程是程序的执行流,每个线程都有自己的程序计数器、虚拟机栈、本地方法栈和一部分堆内存...

    java小程序中动画及音乐多线程的应用源码下载

    Java小程序,通常指的是JavaFX或Swing这样的GUI应用程序,它们可以创建丰富的用户界面,包括动态的动画效果和背景音乐播放。...下载并研究这个源码,将有助于深化对Java多线程编程的理解,提高解决实际问题的能力。

    java多线程作业.docx

    ### Java多线程知识点解析 #### 一、Java多线程概述 Java作为一种现代编程语言,内置了...通过以上分析,我们不仅了解了Java多线程的基本概念和技术细节,还通过具体的代码示例深入了解了多线程在实际编程中的应用。

    java多线程多人聊天系统

    Java多线程多人聊天系统是一种基于网络通信的软件应用,它允许多个用户同时进行实时交流。这个系统的核心在于利用Java的多线程技术来处理并发的用户交互,确保每个用户的输入和输出都能得到及时响应,不会因为其他...

    java 多线程简易聊天 精简版

    Java多线程技术是编程领域中的重要概念,尤其在开发高效、并发的网络应用程序时,如简易聊天程序,它的应用尤为关键。在这个“java 多线程简易聊天 精简版”项目中,我们将深入探讨Java如何实现多线程环境下的客户端...

    多线程并行执行,汇总结果

    "CountDownLatch" 和 "Thread" 是Java编程语言中实现多线程并行执行的关键工具,它们有助于提高程序的运行效率和响应速度。 **多线程并行执行** 多线程并行执行是指在同一个程序中同时运行多个线程,每个线程负责...

    Java多线程编辑核心技术

    在实际开发中,使用Java多线程技术时,开发者可能会面临一些挑战,比如线程安全问题、死锁问题、资源竞争和线程饥饿等。线程安全是指多个线程对共享资源进行访问时,不会导致数据不一致或者程序行为异常。Java虚拟机...

    java多线程实例 代码可执行 绝对开源

    Java多线程是Java编程中的核心概念,尤其在开发高性能、高并发的应用程序时不可或缺。在本实例中,我们探讨的焦点是如何利用Java的多线程特性来实现网络资源的高效下载并进行合并。 首先,Java多线程允许程序同时...

    Java多线程

    Java多线程知识点梳理: 1. Java线程基础知识 - 线程是程序中独立的、并发的执行路径。每个线程都有自己的堆栈、程序计数器和局部变量,但与分隔的进程不同,线程之间的隔离程度较小,它们共享内存、文件句柄等...

    多线程,高并发.zip

    在IT领域,多线程和高并发是两个关键概念,特别是在Java编程中,它们对于构建高效、可扩展的系统至关重要。下面将详细解释这两个概念及其在Java中的实现和应用。 多线程是指在一个应用程序中同时运行多个独立的执行...

    Java多线程详解

    Java多线程是Java编程中的核心概念,它允许程序同时执行多个任务,提高了应用程序的效率和响应速度。在Java中,多线程的实现主要有两种方式:继承Thread类和实现Runnable接口。 一、继承Thread类 当一个类直接继承...

Global site tag (gtag.js) - Google Analytics