线程池实例1:
前序:
Thread-Per-Message Pattern,是一种对于每个命令或请求,都分配一个线程,由这个线程执行工作。它将“委托消息的一端”和“执行消息的一端”用两个不同的线程来实现。该线程模式主要包括三个部分:
1,Request参与者(委托人),也就是消息发送端或者命令请求端
2,Host参与者,接受消息的请求,负责为每个消息分配一个工作线程。
3,Worker参与者,具体执行Request参与者的任务的线程,由Host参与者来启动。
由于常规调用一个方法后,必须等待该方法完全执行完毕后才能继续执行下一步操作,而利用线程后,就不必等待具体任务执行完毕,就可以马上返回继续执行下一步操作。
背景:
由于在Thread-Per-Message Pattern中对于每一个请求都会生成启动一个线程,而线程的启动是很花费时间的工作,所以鉴于此,提出了Worker Thread,重复利用已经启动的线程。
线程池:
Worker Thread,也称为工人线程或背景线程,不过一般都称为线程池。该模式主要在于,事先启动一定数目的工作线程。当没有请求工作的时候,所有的工人线程都会等待新的请求过来,一旦有工作到达,就马上从线程池中唤醒某个线程来执行任务,执行完毕后继续在线程池中等待任务池的工作请求的到达。
任务池:主要是存储接受请求的集合,利用它可以缓冲接受到的请求,可以设置大小来表示同时能够接受最大请求数目。这个任务池主要是供线程池来访问。
线程池:这个是工作线程所在的集合,可以通过设置它的大小来提供并发处理的工作量。对于线程池的大小,可以事先生成一定数目的线程,根据实际情况来动态增加或者减少线程数目。线程池的大小不是越大越好,线程的切换也会耗时的。
存放池的数据结构,可以用数组也可以利用集合,在集合类中一般使用Vector,这个是线程安全的。
Worker Thread的所有参与者:
1,Client参与者,发送Request的参与者
2,Channel参与者,负责缓存Request的请求,初始化启动线程,分配工作线程
3,Worker参与者,具体执行Request的工作线程
4,Request参与者
注意:将在Worker线程内部等待任务池非空的方式称为正向等待。
将在Channel线程提供Worker线程来判断任务池非空的方式称为反向等待。
线程池实例1:
利用同步方法来实现,使用数组来作为任务池的存放数据结构。在Channel有缓存请求方法和处理请求方法,利用生成者与消费者模式来处理存储请求,利用反向等待来判断任务池的非空状态。
Channel参与者:
package whut.threadpool;
//用到了生产者与消费者模式
//生成线程池,接受客户端线程的请求,找到一个工作线程分配该客户端请求
public class Channel {
private static final int MAX_REQUEST = 100;// 并发数目,就是同时可以接受多少个客户端请求
//利用数组来存放请求,每次从数组末尾添加请求,从开头移除请求来处理
private final Request[] requestQueue;// 存储接受客户线程的数目
private int tail;//下一次存放Request的位置
private int head;//下一次获取Request的位置
private int count;// 当前request数量
private final WorkerThread[] threadPool;// 存储线程池中的工作线程
// 运用数组来存储
public Channel(int threads) {
this.requestQueue = new Request[MAX_REQUEST];
this.head = 0;
this.tail= 0;
this.count = 0;
threadPool = new WorkerThread[threads];
// 启动工作线程
for (int i = 0; i < threadPool.length; i++) {
threadPool[i] = new WorkerThread("Worker-" + i, this);
}
}
public void startWorkers() {
for (int i = 0; i < threadPool.length; i++) {
threadPool[i].start();
}
}
// 接受客户端请求线程
public synchronized void putRequest(Request request) {
// 当Request的数量大于或等于同时接受的数目时候,要等待
while (count >= requestQueue.length)
try {
wait();
} catch (InterruptedException e) {
}
requestQueue[tail] = request;
tail = (tail + 1) % requestQueue.length;
count++;
notifyAll();
}
// 处理客户端请求线程
public synchronized Request takeRequest() {
while (count <= 0)
try {
wait();
} catch (InterruptedException e) {
}
Request request = requestQueue[head];
head = (head + 1) % requestQueue.length;
count--;
notifyAll();
return request;
}
}
客户端请求线程:
package whut.threadpool;
import java.util.Random;
//向Channel发送Request请求的
public class ClientThread extends Thread{
private final Channel channel;
private static final Random random=new Random();
public ClientThread(String name,Channel channel)
{
super(name);
this.channel=channel;
}
public void run()
{
try{
for(int i=0;true;i++)
{
Request request=new Request(getName(),i);
channel.putRequest(request);
Thread.sleep(random.nextInt(1000));
}
}catch(InterruptedException e)
{
}
}
}
工作线程:
package whut.threadpool;
//具体工作线程
public class WorkerThread extends Thread{
private final Channel channel;
public WorkerThread(String name,Channel channel)
{
super(name);
this.channel=channel;
}
public void run()
{
while(true)
{
Request request=channel.takeRequest();
request.execute();
}
}
}
线程池实例2:
工作线程:
利用同步块来处理,利用Vector来存储客户端请求。在Channel有缓存请求方法和处理请求方法,利用生成者与消费者模式来处理存储请求,利用正向等待来判断任务池的非空状态。
这种实例,可以借鉴到网络ServerSocket处理用户请求的模式中,有很好的扩展性与实用性。
利用Vector来存储,依旧是每次集合的最后一个位置添加请求,从开始位置移除请求来处理。
Channel参与者:
package whut.threadpool2;
import java.util.Vector;
/*
* 这个主要的作用如下
* 0,缓冲客户请求线程(利用生产者与消费者模式)
* 1,存储客户端请求的线程
* 2,初始化启动一定数量的线程
* 3,主动来唤醒处于任务池中wait set的一些线程来执行任务
*/
public class Channel {
public final static int THREAD_COUNT=4;
public static void main(String[] args) {
//定义两个集合,一个是存放客户端请求的,利用Vector,
//一个是存储线程的,就是线程池中的线程数目
//Vector是线程安全的,它实现了Collection和List
//Vector 类可以实现可增长的对象数组。与数组一样,
//它包含可以使用整数索引进行访问的组件。但Vector 的大小可以根据需要增大或缩小,
//以适应创建 Vector 后进行添加或移除项的操作。
//Collection中主要包括了list相关的集合以及set相关的集合,Queue相关的集合
//注意:Map不是Collection的子类,都是java.util.*下的同级包
Vector pool=new Vector();
//工作线程,初始分配一定限额的数目
WorkerThread[] workers=new WorkerThread[THREAD_COUNT];
//初始化启动工作线程
for(int i=0;i<workers.length;i++)
{
workers[i]=new WorkerThread(pool);
workers[i].start();
}
//接受新的任务,并且将其存储在Vector中
Object task=new Object();//模拟的任务实体类
//此处省略具体工作
//在网络编程中,这里就是利用ServerSocket来利用ServerSocket.accept接受一个Socket从而唤醒线程
//当有具体的请求达到
synchronized(pool)
{
pool.add(pool.size(), task);
pool.notifyAll();//通知所有在pool wait set中等待的线程,唤醒一个线程进行处理
}
//注意上面这步骤添加任务池请求,以及通知线程,都可以放在工作线程内部实现
//只需要定义该方法为static,在方法体用同步块,且共享的线程池也是static即可
//下面这步,可以有可以没有根据实际情况
//取消等待的线程
for(int i=0;i<workers.length;i++)
{
workers[i].interrupt();
}
}
}
工作线程:
package whut.threadpool2;
import java.util.List;
public class WorkerThread extends Thread {
private List pool;//任务请求池
private static int fileCompressed=0;//所有实例共享的
public WorkerThread(List pool)
{
this.pool=pool;
}
//利用静态synchronized来作为整个synchronized类方法,仅能同时一个操作该类的这个方法
private static synchronized void incrementFilesCompressed()
{
fileCompressed++;
}
public void run()
{
//保证无限循环等待中
while(true)
{
//共享互斥来访问pool变量
synchronized(pool)
{
//利用多线程设计模式中的
//Guarded Suspension Pattern,警戒条件为pool不为空,否则无限的等待中
while(pool.isEmpty())
{
try{
pool.wait();//进入pool的wait set中等待着,释放了pool的锁
}catch(InterruptedException e)
{
}
}
//当线程被唤醒,需要重新获取pool的锁,
//再次继续执行synchronized代码块中其余的工作
//当不为空的时候,继续再判断是否为空,如果不为空,则跳出循环
//必须先从任务池中移除一个任务来执行,统一用从末尾添加,从开始处移除
pool.remove(0);//获取任务池中的任务,并且要进行转换
}
//下面是线程所要处理的具体工作
}
}
}
from: http://developer.51cto.com/art/201305/395279_1.htm
分享到:
相关推荐
《JAVA多线程设计模式》PDF 下载 《Java线程 高清晰中文第二版》中文第二版(PDF) 前言 第一章 线程简介 Java术语 线程概述 为什么要使用线程? 总结 第二章 Java线程API 通过Thread类创建线程 使用Runable接口...
java多线程设计模式,附源码中文教程,java并发核心编程,JAVA线程池原理以及几种线程池类型介绍
java多线程相关内容,介绍了多线程基本知识,线程池,线程并发数据结构,线程设计模式等重点内容,难点内容。
01、【中级原理】java多线程并发编程入门原理精通视频教程 02、【中级原理专题】java并发编程多线程高级专题课程 03. 【中级原理】高并发编程原理和线程池精通教程 04、【高级原理】Java并发多线程编程基础原理与...
利用java多线程并发机制实现了多个聊天app的跑字典登录功能 实现了跑字典登录某app的功能! 使用第三方库以及技术 okhttp3 线程池 策略设计模式 简单工厂设计模式 利用java多线程并发机制实现了...
思维导图参考: 【十三】Java多线程思维导图 一、什么是线程 什么是进程 什么是线程 线程,又称轻量级进程(Light Weight Process) 程序中的一个顺序控制流程,同时也是CPU的基本调度单位 比如: 迅雷是一个进程...
本书全面解析了Java并发编程的核心概念、原理和实践,帮助读者深入理解多线程并发编程的精髓,提升编程能力和系统性能。 书中首先介绍了并发编程的基础知识,包括线程的基本概念、线程的生命周期、线程安全等问题。...
1. 多线程和并发编程:学习使用Java并发包(如java.util.concurrent)处理多线程编程,了解线程池、锁机制和并发集合等。 2. 性能优化:学习分析和调优Java应用程序的性能,了解内存管理、垃圾回收、性能监测和调优...
十二、 多线程★★★★ 39 为什么要使用多线程 39 创建线程和启动 39 线程的生命周期 44 线程管理 45 线程同步 49 线程通信 52 线程池 58 死锁 64 线程相关类 65 十三、 同步★★★★★ 67 十四、 Lock接口 70 十五...
线程、多线程和线程池面试专题 Android面试中常被问基础知识点汇总宝典 初级面试专题(中小厂) 混合跨平台开发面试题 设计模式面试专题及答案 中高级专题(View+Handler+Binder) 底层机制突破 面试必备之乐观锁与...
这是《计算机网络》的课程设计--多线程的Web服务器(带有课程设计报告),里面为Eclipse3.5的工程。支持HTTP1.1(但是不完善),支持多线程(采用的线程池),支持简单CGI(仅PHP的CGI模块通过测试),支持配置文件...
7种常见的设计模式及使用场景 Java必会基础与新版本特性 线上问题排查 集合框架 哈希映射 并发哈希映射 数组列表 向量 深入浅出JVM JVM内存模型 性能调优、线上问题排查 类加载机制详解 垃圾回收机制 垃圾回收...
7种常见的设计模式和使用场景 Java必会基础与新版本特性 集合框架 JVM内存模型 性能调优、线上问题排查 类加载机制详解 垃圾回收机制 垃圾回收器、垃圾回收算法 并发与多线程 多线程基础知识 常见关键字 多线程锁...
线程、多线程和线程池面试专题.docx 网络编程面试专题.docx 腾讯Android社招面试源码相关11题+原理详解.docx 设计模式面试专题.docx 设计模式面试专题及答案.pdf 面试必备之乐观锁与悲观锁.pdf 高级面试题.docx
线程、多线程和线程池面试专题.docx 网络编程面试专题.docx 腾讯Android社招面试源码相关11题+原理详解.docx 设计模式面试专题.docx 设计模式面试专题及答案.pdf 面试必备之乐观锁与悲观锁.pdf 高级面试题.docx
JAVA中级认证知识点 异常 工具类 设计模式 IO流体系 堆栈分析 多线程、线程池、线程安全 JVM内存模型、垃圾回收
设计:Java实现设计模式basic:Java基础代码实践leet:Leetcode刷题nettt:netty库实践Spring:Spring基础原理及实践mq-courier:spring boot2.0 + rabbitMQ / kafka / rocket常见的MQ实践分布式锁:redis,...
多线程编程:涉及线程的创建、同步与互斥、线程池、线程间通信等多线程编程的知识。 IO操作:包括文件读写、字符流和字节流、序列化与反序列化等IO操作的相关知识。 JDBC和数据库:涉及JDBC的使用、连接数据库、...
│ │ 9.JAVA并发编程之多线程并发同步业务场景与解决方案.wmv │ │ │ ├─10.微服务架构之Spring Cloud Eureka 场景分析与实战 │ │ 10.微服务架构之Spring Cloud Eureka 场景分析与实战.wmv │ │ │ ├─11....
单例模式的线程安全日志记录器类:需要设计一个类,保证在多线程环境下只有一个实例存在,并能够正确记录日志信息。 并发安全的阻塞队列类:需要设计一个线程安全的队列类,支持多线程的插入和移除操作,能够正确...