`
xmong
  • 浏览: 263332 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

java多线程设计模式之队列通信

阅读更多
Java实现多线程处理队列请求通信:客户端线程向请求队列中不断发生请求,服务器端线程不断处理请求队列中请求。
一个线程(ClientThread)对另一线程(ServerThread)传递请求(request)的实例。实现简单的线程沟通。
设计如下:
Request:请求类,存储请求信息的类。
RequestQueue:请求队列类,接受存储请求的队列类。
ClientThread:发送请求的线程类,负责向请求队列中发送请求。
ServerThread:处理请求的线程类,负责向请求队列中取请求处理。
Mian:程序入口

Request:请求类,存储发生信息的类。

package com.single.queue;

/**
 * 
 * @author Administrator
 * 请求类
 */
public class Request {

	/**
	 * 请求名称
	 */
	private final String name;
	
	public Request(String name){
		this.name = name;
	}
	
	public String getName(){
		return name;
	}
	
	public String toString(){
		return "{Request."+name+"}";
	}
	
}

Request类中只存放了请求的名字信息。


RequestQueue:请求队列,用例存放请求的队列类。

package com.single.queue;

import java.util.LinkedList;

/**
 * 
 * @author Administrator
 *	请求队列
 */
public class RequestQueue {

	/**
	 * 请求队列
	 */
	private final LinkedList<Request> queue = new LinkedList<Request>();
	
	/**
	 * 同步取出队列中的请求
	 * @return
	 */
	public synchronized Request getRequest(){
		while(queue.size()<=0){
			try {
				System.out.println("{getRequest wait}");
				wait(); //如果队列为空,则当前线程进入等待池中
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		Request request = queue.removeFirst();
		System.out.println(Thread.currentThread().getName()+" getRequest "+request);
		return request;
	}
	
	/**
	 * 同步向队列中加入请求
	 * @param request
	 */
	public synchronized void putRequest(Request request){
		queue.addLast(request);
		System.out.println(Thread.currentThread().getName()+" putRequest "+request);
		notifyAll(); //队列中加入请求后,换醒等待线程处理请求
	}
	
}

RequestQueue类用来存放请求的类,这个类拥有putRequest和getRequest两个方法;
putRequest方法是实现将请求(request)存放到请求队列中(requestQueue),客户端线程会调用此方法来发生请求并保持到请求队列中。
getRequest方法是实现将请求(request)从请求队列中(requestQueue)中取出,服务器端线程就会调用此方法将请求队列中的请求取出并处理。

ClientThread:客户端线程,发送请求的线程类。

package com.single.queue;

import java.util.Random;

/**
 * 
 * @author Administrator
 *	客户端线程负责发送请求
 */
public class ClientThread extends Thread{

	/**
	 * 请求队列
	 */
	private RequestQueue requestQueue;
	/**
	 * client名称
	 */
	private String name;
	
	public ClientThread(String name, RequestQueue queue){
		super("client."+name);
		this.name = name;
		this.requestQueue = queue;
	}
	
	/**
	 * 循环加入多个请求
	 */
	public void run(){
		for (int i = 0; i < 10; i++) {
			Request request = new Request(name+"."+i);
			requestQueue.putRequest(request);
			try {
				Thread.sleep(new Random().nextInt(1010));
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			
		}
	}
	
}


ServerThread:服务器端线程,处理请求的线程类

package com.single.queue;

import java.util.Random;

/**
 * 
 * @author Administrator
 *	服务线程负责处理请求
 */
public class ServerThread extends Thread{

	/**
	 * 请求队列
	 */
	private RequestQueue requestQueue;
	
	public ServerThread(String name,RequestQueue queue){
		super("server."+name);
		this.requestQueue = queue;
	}
	
	/**
	 * 循环取出请求
	 */
	public void run(){
		for (int i = 0; i < 10; i++) {
			requestQueue.getRequest();
			try {
				Thread.sleep(new Random().nextInt(1000));
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			
		}
	}
	
}



Main:main程序执行入口

package com.single.queue;

/**
 * 
 * @author Administrator
 *	main
 */
public class Main {

	/**
	 * 客户端线程请求向队列中不断发送请求,服务器端线程不断处理请求。
	 * @param args
	 */
	public static void main(String[] args) {
		RequestQueue queue = new RequestQueue();
		new ClientThread("a",queue).start();
		new ServerThread("a",queue).start();
	}
	
}

执行结果:

client.a putRequest {Request.a.0}
server.a getRequest {Request.a.0}
client.a putRequest {Request.a.1}
server.a getRequest {Request.a.1}
{getRequest wait}
client.a putRequest {Request.a.2}
server.a getRequest {Request.a.2}
client.a putRequest {Request.a.3}
server.a getRequest {Request.a.3}
{getRequest wait}
client.a putRequest {Request.a.4}
server.a getRequest {Request.a.4}
{getRequest wait}
client.a putRequest {Request.a.5}
server.a getRequest {Request.a.5}
{getRequest wait}
client.a putRequest {Request.a.6}
server.a getRequest {Request.a.6}
client.a putRequest {Request.a.7}
client.a putRequest {Request.a.8}
server.a getRequest {Request.a.7}
server.a getRequest {Request.a.8}
{getRequest wait}
client.a putRequest {Request.a.9}
server.a getRequest {Request.a.9}



上面了列子只是一个单线程与单线程通信的列子,如果我们想要看多个线程与多个线程通信,则只需要修改main方法就可以实现:

public static void main(String[] args) {
		RequestQueue queue = new RequestQueue();
		new ClientThread("a",queue).start();
		new ServerThread("a",queue).start();
		new ClientThread("b",queue).start();
		new ServerThread("b",queue).start();
	}


修改后的执行结果如下:

client.a putRequest {Request.a.0}
client.b putRequest {Request.b.0}
server.a getRequest {Request.a.0}
server.b getRequest {Request.b.0}
{getRequest wait}
client.a putRequest {Request.a.1}
server.a getRequest {Request.a.1}
client.b putRequest {Request.b.1}
server.a getRequest {Request.b.1}
{getRequest wait}
client.a putRequest {Request.a.2}
server.b getRequest {Request.a.2}
{getRequest wait}
{getRequest wait}
client.b putRequest {Request.b.2}
server.a getRequest {Request.b.2}
{getRequest wait}
{getRequest wait}
client.b putRequest {Request.b.3}
server.a getRequest {Request.b.3}
{getRequest wait}
{getRequest wait}
client.a putRequest {Request.a.3}
server.a getRequest {Request.a.3}
{getRequest wait}
client.a putRequest {Request.a.4}
server.b getRequest {Request.a.4}
client.b putRequest {Request.b.4}
server.b getRequest {Request.b.4}
client.a putRequest {Request.a.5}
client.a putRequest {Request.a.6}
server.a getRequest {Request.a.5}
……




分享到:
评论

相关推荐

    JAVA多线程设计模式.pdf 下载

    标题和描述均指向了一个关于Java多线程设计模式的PDF文档的下载链接,这暗示了文档的主要内容将围绕Java中的多线程编程及其设计模式展开。在Java领域,多线程是一个核心概念,它允许程序执行多个任务同时进行,极大...

    java多线程设计模式_java_设计模式_多线程_多线程课题_

    Java多线程设计模式是Java开发中的核心概念,它涉及到如何高效、安全地在多个执行线程之间共享资源和协调任务。设计模式是解决特定问题的成熟方案,它们是编程经验的结晶,可以帮助开发者在面临多线程挑战时快速找到...

    java多线程设计模式详解(PDF及源码).zip

    Java多线程设计模式是Java开发中的重要领域,它涉及到如何高效、安全地利用系统资源进行并发处理。在这个主题中,我们将深入探讨单线程、生产者与消费者模型以及Java中实现多线程的各种方法。 首先,单线程是程序...

    Java多线程设计模式源代码

    总之,这份Java多线程设计模式源代码涵盖了从基本的线程创建到复杂的线程同步、通信和线程池管理,以及各种线程安全的类和设计模式的实战应用。通过学习和分析这些源码,开发者能够更好地理解和掌握Java多线程编程,...

    Java多线程设计模式(带源码)

    Java多线程设计模式是Java开发中的重要领域,它涉及到并发编程、系统性能优化以及程序的稳定性。在Java中,多线程允许程序同时执行多个任务,极大地提升了程序的执行效率。本资源提供了详细的Java多线程设计模式的...

    java多线程设计模式详解(PDF及源码)

    《Java多线程设计模式详解》是一本深入探讨Java并发编程和设计模式的专业书籍,它涵盖了多线程环境下的各种核心概念、最佳实践以及常见问题的解决方案。这本书旨在帮助开发者在实际开发过程中更好地理解和应用多线程...

    java 多线程 队列工厂

    在`queueFactory`压缩包中,可能包含了示例代码或者类库,展示了如何使用队列工厂模式来创建和管理不同类型的队列,特别是针对Java多线程环境的优化。这些资源可以帮助开发者更好地理解和应用多线程和队列技术,提高...

    java多线程设计模式详解

    Java多线程设计模式是Java编程中不可或缺的一部分,它涉及到如何在并发环境下高效、安全地组织代码执行。本文将深入探讨几种常见的Java多线程设计模式,并提供源码实例进行详细解析。 一、生产者消费者模式 生产者...

    java多线程设计模式

    ### Java多线程设计模式详解 #### 一、Java多线程基础 Java语言自诞生以来,便内置了对多线程的支持。多线程可以让应用程序在同一时间处理多个任务,提高程序的执行效率和响应速度。Java中创建线程有两种基本方式...

    Java多线程设计模式上传文件

    综上所述,Java多线程和设计模式的结合使得文件上传任务能够高效、安全地执行。通过合理的设计和实现,我们可以创建一个可扩展、易维护的文件上传系统,满足各种复杂的需求。具体到项目中的源代码,应该包含了对上述...

    JAVA设计模式与JAVA多线程设计模式详解

    在Java编程领域,设计模式和多线程设计模式是开发者必备的技能。设计模式是一种在特定情境下解决软件设计问题的通用、可复用的解决方案,而多线程设计模式则是处理并发问题的关键。本文将深入探讨这两种重要的概念,...

    java 多线程编程实战指南(核心 + 设计模式 完整版)

    《Java多线程编程实战指南》这本书深入浅出地讲解了Java多线程的核心概念和实战技巧,分为核心篇和设计模式篇,旨在帮助开发者掌握并应用多线程技术。 1. **线程基础** - **线程的创建**:Java提供了两种创建线程...

    Java 多线程编程中的设计模式~

    ### 二、Java多线程设计模式的重要性 在Java中,多线程设计模式的重要性不言而喻。由于多线程环境的复杂性,如果不采用合适的设计模式,很容易导致死锁、数据不一致、竞态条件等并发问题。因此,熟悉并运用这些设计...

    Java多线程设计模式

    Java多线程设计模式是程序开发中的重要领域,特别是在服务器端和高性能应用中,多线程的使用可以显著提升系统的并行处理能力。本书由知名技术作者结城浩撰写,于2005年出版,得到了广泛的好评,被誉为“好书”。这...

    java多线程设计模式详解+源码

    Java多线程设计模式是Java开发中不可或缺的一部分,它涉及到并发编程的核心理论和技术。在Java中,多线程用于提高程序的执行效率,通过同时执行多个任务来利用系统资源。本资料包包含“java多线程设计模式详解”文档...

Global site tag (gtag.js) - Google Analytics