- 浏览: 262734 次
- 性别:
- 来自: 深圳
文章分类
- 全部博客 (88)
- JAVA / base (26)
- JAVA / web (12)
- JAVA / Lib-tools (5)
- SERVER / tomcat (4)
- DB / mysql (4)
- DB / mongodb (2)
- DB / memcached (2)
- DB / redis (2)
- WEB / Front-end (3)
- WEB / security (4)
- WEB / css (2)
- WEB / js (4)
- OS / linux (3)
- IT / Architecture (4)
- IT / other (2)
- Android (9)
- Go (1)
- Other (1)
- OS / Mac (2)
最新评论
-
Zero2Max:
哈哈,马士兵老师也发现了。
java实现接口的bug -
xly1981:
能像CSRF攻击一样带个图就更棒了
XSS跨站攻击 -
xmong:
df274119386 写道在javascript中看到下面的 ...
CSRF攻击与防御策略 -
df274119386:
在javascript中看到下面的语句 e.value = t ...
CSRF攻击与防御策略 -
xmong:
yzxqml 写道xmong 写道yzxqml 写道tomca ...
Tomcat集群
Java实现多线程处理队列请求通信:客户端线程向请求队列中不断发生请求,服务器端线程不断处理请求队列中请求。
一个线程(ClientThread)对另一线程(ServerThread)传递请求(request)的实例。实现简单的线程沟通。
设计如下:
Request:请求类,存储请求信息的类。
RequestQueue:请求队列类,接受存储请求的队列类。
ClientThread:发送请求的线程类,负责向请求队列中发送请求。
ServerThread:处理请求的线程类,负责向请求队列中取请求处理。
Mian:程序入口
Request:请求类,存储发生信息的类。
Request类中只存放了请求的名字信息。
RequestQueue:请求队列,用例存放请求的队列类。
RequestQueue类用来存放请求的类,这个类拥有putRequest和getRequest两个方法;
putRequest方法是实现将请求(request)存放到请求队列中(requestQueue),客户端线程会调用此方法来发生请求并保持到请求队列中。
getRequest方法是实现将请求(request)从请求队列中(requestQueue)中取出,服务器端线程就会调用此方法将请求队列中的请求取出并处理。
ClientThread:客户端线程,发送请求的线程类。
ServerThread:服务器端线程,处理请求的线程类
Main:main程序执行入口
执行结果:
上面了列子只是一个单线程与单线程通信的列子,如果我们想要看多个线程与多个线程通信,则只需要修改main方法就可以实现:
修改后的执行结果如下:
一个线程(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 validation(java验证器实现)
2014-03-18 11:45 3693Java validation 1. java验证器 在 ... -
Memo class备注类信息
2014-03-18 09:52 882Memo Class 1. 什么是Memo Class Mem ... -
java annotation注解
2014-01-24 18:01 9461. Annotation的声明方式 An ... -
Java RMI
2013-03-28 15:12 1712Java Rmi 目录 1 JAVA RMI 1 ... -
java内部类
2013-03-19 16:25 1041Java内部类 目录 1 JAVA ... -
java多线程设计模式之订单模式
2013-03-11 14:00 2684Java多线程实现订单模式: 客户端线程向服务端发起请求后, ... -
java多线程设计模式之线程池处理请求
2013-03-08 17:50 1818Java实现线程池处理请求: 客户端线程发出请求,请求存入请 ... -
java多线程设计模式之异步处理请求
2013-03-08 12:36 4525Java实现多线程异步处理请求: Java实现多线程异步处理 ... -
java多线程设计模式之读写文件模式
2013-03-07 17:56 1586Java实现多线程读写数据 ... -
java多线程设计模式之生产者与消费者
2013-03-07 11:34 1053Java实现多线程生产者与消费者: 生产者线程负责生产产品 ... -
java多线程设计模式之文件保存
2013-03-06 16:16 1606Java实现多线程保存文件:两线程去保存文件,一个保存线程定时 ... -
Java读linux系统文件文件名乱码
2012-12-06 17:01 91601,问题描述 web应用想通过Java读取linux系统文件显 ... -
Java安全加密
2012-11-28 10:24 1972安全加密 目录 1 加密安全 1 1.1 应用的安全 1 ... -
图着色问题
2012-11-27 13:05 3110图着色问题 目录 1 图 ... -
JDK6新特性
2012-07-03 23:24 2898JDK6的新特性 JDK6的新特性之一_Desktop类 ... -
JDK7新特性
2012-07-03 15:39 3505JDK7新特性 一 JDK7新特性简介 准备 JDK7下载 ... -
JDK5新特性
2012-07-03 10:23 73JDK5.0新特性 1.自动封箱和自动解封(简单类型和封装类 ... -
java多线程
2012-06-15 15:12 1561Java多线程 目录 1 线 ... -
代理模式
2012-06-13 14:12 1367代理模式 目录 1 代理 ... -
java垃圾回收机制
2012-06-11 11:30 2562Java内存回收 目录 1 JAVA内存STACK和HE ...
相关推荐
标题和描述均指向了一个关于Java多线程设计模式的PDF文档的下载链接,这暗示了文档的主要内容将围绕Java中的多线程编程及其设计模式展开。在Java领域,多线程是一个核心概念,它允许程序执行多个任务同时进行,极大...
Java多线程设计模式是Java开发中的核心概念,它涉及到如何高效、安全地在多个执行线程之间共享资源和协调任务。设计模式是解决特定问题的成熟方案,它们是编程经验的结晶,可以帮助开发者在面临多线程挑战时快速找到...
Java多线程设计模式是Java开发中的重要领域,它涉及到如何高效、安全地利用系统资源进行并发处理。在这个主题中,我们将深入探讨单线程、生产者与消费者模型以及Java中实现多线程的各种方法。 首先,单线程是程序...
总之,这份Java多线程设计模式源代码涵盖了从基本的线程创建到复杂的线程同步、通信和线程池管理,以及各种线程安全的类和设计模式的实战应用。通过学习和分析这些源码,开发者能够更好地理解和掌握Java多线程编程,...
Java多线程设计模式是Java开发中的重要领域,它涉及到并发编程、系统性能优化以及程序的稳定性。在Java中,多线程允许程序同时执行多个任务,极大地提升了程序的执行效率。本资源提供了详细的Java多线程设计模式的...
《Java多线程设计模式详解》是一本深入探讨Java并发编程和设计模式的专业书籍,它涵盖了多线程环境下的各种核心概念、最佳实践以及常见问题的解决方案。这本书旨在帮助开发者在实际开发过程中更好地理解和应用多线程...
在`queueFactory`压缩包中,可能包含了示例代码或者类库,展示了如何使用队列工厂模式来创建和管理不同类型的队列,特别是针对Java多线程环境的优化。这些资源可以帮助开发者更好地理解和应用多线程和队列技术,提高...
Java多线程设计模式是Java编程中不可或缺的一部分,它涉及到如何在并发环境下高效、安全地组织代码执行。本文将深入探讨几种常见的Java多线程设计模式,并提供源码实例进行详细解析。 一、生产者消费者模式 生产者...
### Java多线程设计模式详解 #### 一、Java多线程基础 Java语言自诞生以来,便内置了对多线程的支持。多线程可以让应用程序在同一时间处理多个任务,提高程序的执行效率和响应速度。Java中创建线程有两种基本方式...
综上所述,Java多线程和设计模式的结合使得文件上传任务能够高效、安全地执行。通过合理的设计和实现,我们可以创建一个可扩展、易维护的文件上传系统,满足各种复杂的需求。具体到项目中的源代码,应该包含了对上述...
在Java编程领域,设计模式和多线程设计模式是开发者必备的技能。设计模式是一种在特定情境下解决软件设计问题的通用、可复用的解决方案,而多线程设计模式则是处理并发问题的关键。本文将深入探讨这两种重要的概念,...
《Java多线程编程实战指南》这本书深入浅出地讲解了Java多线程的核心概念和实战技巧,分为核心篇和设计模式篇,旨在帮助开发者掌握并应用多线程技术。 1. **线程基础** - **线程的创建**:Java提供了两种创建线程...
### 二、Java多线程设计模式的重要性 在Java中,多线程设计模式的重要性不言而喻。由于多线程环境的复杂性,如果不采用合适的设计模式,很容易导致死锁、数据不一致、竞态条件等并发问题。因此,熟悉并运用这些设计...
Java多线程设计模式是程序开发中的重要领域,特别是在服务器端和高性能应用中,多线程的使用可以显著提升系统的并行处理能力。本书由知名技术作者结城浩撰写,于2005年出版,得到了广泛的好评,被誉为“好书”。这...
Java多线程设计模式是Java开发中不可或缺的一部分,它涉及到并发编程的核心理论和技术。在Java中,多线程用于提高程序的执行效率,通过同时执行多个任务来利用系统资源。本资料包包含“java多线程设计模式详解”文档...