- 浏览: 71157 次
- 性别:
- 来自: 深圳
文章分类
最新评论
-
Alex_Cheung:
对了,第二个没有提取码,请知悉。
一大波视频分享 -
Alex_Cheung:
谢谢分享。
一大波视频分享 -
Jiy:
很详细,谢谢分享
java并发之同步辅助类Phaser -
walle1027:
非常不错,学习了。
java并发之同步辅助类Phaser -
huangjinjin520:
somefuture 写道除了单词写错了 其他挺好的已更正
dubbo注解使用详解
今天来学学,大家也好对线程池有一个更好的理解。
public class Main {
public static void main(String[] args) {
Channel channel = new Channel(5); // 工人线程的數量,即线程池内的线程数目
channel.startWorkers();//启动线程池内的线程
new ClientThread("Alice", channel).start();//发送请求的线程,相当于向队列加入请求
new ClientThread("Bobby", channel).start();
new ClientThread("Chris", channel).start();
}
}
发送请求的client代码:
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 {
int i = 0;
Request request = new Request(getName(), i);//生成请求
channel.putRequest(request);//向队列中放入请求,也即把请求传给线程池
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
}
ClientThread建立请求,并把请求传给了channel,下面来看看channel类(相当于线程池类)
public class Channel {
private static final int MAX_REQUEST = 100;
private final Request[] requestQueue;//存放请求的队列
private int tail; // 下一个putRequest的地方
private int head; // 下一个takeRequest的地方
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) {//向队列中存入请求
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;
}
}
channel类把传给他的请求放入队列中,等待worker去取请求,下面看看worker(即工作线程,线程池中已经初始话好的线程)
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();//处理请求
}
}
}
在工作线程中会从线程池的队列里取出请求,并对请求进行处理。这里的workerthread相当于背景线程,他一直都在运行,当有请求的时候,他就会进行处理,这里处理请求的线程是已经存在在channel(线程池里的线程),他不会因为请求的增加而增加(这是本例中的情况),不会来一个请求就新建立一个线程,节省了资源。
再看看请求的代码:
public class Request {
private final String name; // 委托者
private final int number; // 请求编号
private static final Random random = new Random();
public Request(String name, int number) {
this.name = name;
this.number = number;
}
public void execute() {//执行请求
System.out.println(Thread.currentThread().getName() + " executes " + this);
try {
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
public String toString() {
return "[ Request from " + name + " No." + number + " ]";
}
}
JAVA SDK所写的 ExecutorService,其就相当于channel,即线程池。至于其实现当然要比channel复杂多了,channel只是举个例子。而WorkerThread可不是工作线程,他相当于发送到channel的请求,也就是request,当执行代码:tpes.execute(workers[i]);时,相当于向线程池加入一个请求,而WorkerThread中的run则相当于request中的execute,这也是当执行tpes.execute(workers[i]);时,并不会产生新的线程的原因。ExecutorService中产生的背景线程(相当于本篇的WorkerThread )我们是看不到的。
各种it视频获取
public class Main {
public static void main(String[] args) {
Channel channel = new Channel(5); // 工人线程的數量,即线程池内的线程数目
channel.startWorkers();//启动线程池内的线程
new ClientThread("Alice", channel).start();//发送请求的线程,相当于向队列加入请求
new ClientThread("Bobby", channel).start();
new ClientThread("Chris", channel).start();
}
}
发送请求的client代码:
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 {
int i = 0;
Request request = new Request(getName(), i);//生成请求
channel.putRequest(request);//向队列中放入请求,也即把请求传给线程池
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
}
ClientThread建立请求,并把请求传给了channel,下面来看看channel类(相当于线程池类)
public class Channel {
private static final int MAX_REQUEST = 100;
private final Request[] requestQueue;//存放请求的队列
private int tail; // 下一个putRequest的地方
private int head; // 下一个takeRequest的地方
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) {//向队列中存入请求
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;
}
}
channel类把传给他的请求放入队列中,等待worker去取请求,下面看看worker(即工作线程,线程池中已经初始话好的线程)
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();//处理请求
}
}
}
在工作线程中会从线程池的队列里取出请求,并对请求进行处理。这里的workerthread相当于背景线程,他一直都在运行,当有请求的时候,他就会进行处理,这里处理请求的线程是已经存在在channel(线程池里的线程),他不会因为请求的增加而增加(这是本例中的情况),不会来一个请求就新建立一个线程,节省了资源。
再看看请求的代码:
public class Request {
private final String name; // 委托者
private final int number; // 请求编号
private static final Random random = new Random();
public Request(String name, int number) {
this.name = name;
this.number = number;
}
public void execute() {//执行请求
System.out.println(Thread.currentThread().getName() + " executes " + this);
try {
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
public String toString() {
return "[ Request from " + name + " No." + number + " ]";
}
}
JAVA SDK所写的 ExecutorService,其就相当于channel,即线程池。至于其实现当然要比channel复杂多了,channel只是举个例子。而WorkerThread可不是工作线程,他相当于发送到channel的请求,也就是request,当执行代码:tpes.execute(workers[i]);时,相当于向线程池加入一个请求,而WorkerThread中的run则相当于request中的execute,这也是当执行tpes.execute(workers[i]);时,并不会产生新的线程的原因。ExecutorService中产生的背景线程(相当于本篇的WorkerThread )我们是看不到的。
各种it视频获取
发表评论
-
一大波视频分享
2018-06-09 09:36 11381.ps 链接: https://pan.baidu ... -
利用Sharding-Jdbc实现分表
2018-05-24 22:32 3774你们团队使用SpringMVC+Spr ... -
MINA原理详解
2018-05-19 13:51 14861. 通过SocketConnector同服务器端建立连接 ... -
最近有人说我欺骗消费者,今天来一波视频分享
2018-05-12 21:00 1236最近有人说我欺骗消费者,今天来一波视频分享 dubbo入门 ... -
SVN多版本库环境的搭建
2018-05-02 21:00 1194一、 1、启动SVN sudo svn ... -
前端 Java Python等资源合集大放送
2018-04-21 22:11 695如果需要学习视频,欢 ... -
Nginx会话保持之nginx-sticky-module模块
2018-04-16 20:34 1964在使用负载均衡的时候会遇到会话保持的问题,常用的方法有: 1. ... -
dubbo源码学习(四):暴露服务的过程
2018-04-14 11:38 978dubbo采用的nio异步的通信,通信协议默认为 netty, ... -
dubbo源码学习(四)初始化过程细节:解析服务
2018-04-12 20:32 612今天将真正去看dubbo内部的实现过程,看dubbo的源码前我 ... -
dubbo源码学习(二) : spring 自定义标签
2018-04-09 20:29 630做dubbo的配置时很容易发现,dubbo有一套自己的标签,提 ... -
Dubbo多注册中心和Zookeeper服务的迁移
2018-04-06 08:58 1501一、Dubbo多注册中心 1、 应用场景 例如阿里有些服务 ... -
dubbo源码学习一:基础知识及使用的相关技术
2018-04-05 20:10 689Dubbo是Alibaba开源的分布式服务框架,它最大的特点是 ... -
线程各种状态转移分析
2018-03-28 22:13 898线程在它的生命周期 ... -
生产者-消费者模式实现
2018-03-26 22:45 1159生产者是指:生产数据的线程 消费者是指:使用数据的线程 生产者 ... -
java并发之同步辅助类Phaser
2018-03-19 21:46 1102Phaser含义: 更加复杂和强大的同步辅助类。它允许并发执 ... -
java并发之同步辅助类CyclicBarrier
2018-03-18 20:13 832CyclicBarrier含义: 栅栏允许两个或者多个线程在 ... -
java并发之同步辅助类semaphore
2018-03-14 21:24 779semaphore(seməˌfôr)含义: 信号量就是可以 ... -
Tomcat 集群 文件上传下载的共享问题 NFS配置
2018-03-12 21:50 661Tomcat 集群时上传文件时如何使得多部tomcat中的文件 ... -
it技术谱图分享
2018-03-10 22:05 5141、程序开发语言综述 2、前端工程师必备技能 3、 ... -
捋一捋dubbo配置
2018-03-07 22:37 550配置类关系(Configuration Relation) ...
相关推荐
当面对高并发访问时,为了提升系统性能和可用性,我们可以采用负载均衡策略,其中"worker模式"是Apache mod_proxy模块的一种配置方式,用于实现对后端Tomcat服务器的负载均衡。 Apache的mod_proxy模块允许我们配置...
prefork 模式更适合内存有限且需要高度稳定性的环境,而 worker 模式则适用于需要处理大量并发请求且所有模块都线程安全的情况。但请注意,不是所有 PHP 模块都支持线程安全,因此在使用 worker 模式时需要额外注意...
apache常用的工作模式有prefork和worker模式。运行命令httpd -l 或者apache2 -l ,输出的结果中如果含有prefork.c,那就是prefork模式,如果结果中含有worker.c,那就是worker模式。 知道模式之后我们可以在apache的...
worker模式使用多个子进程,每个子进程有多个线程。每个线程在某个确定的时间只能维持一个连接。通常来说,在一个高流量的HTTP服务器 上,Worker MPM是个比较好的选择,因为Worker MPM的内存使用比Prefork MP
这是master-worker模式自我恢复能力的关键部分。 4. **进程管理**: - 通过`ps -aux`命令可以看到运行的进程状态。在示例中,master_process和多个worker_process清晰可见。 - 当手动杀死一个worker进程(如kill ...
为Couchbase Sync Gateway实现Change Worker模式的基于Java的工具 特征 支持Couchbase Sync Gateway 2.0 充当 (包括相同参数)的客户端 实现websocket和连续供稿类型 序列存储:支持将最后一个序列保存在Sync ...
Apache2 的 Worker 工作模式配置及 MaxClients 不足问题解决 Apache 服务器是当前最流行的 Web 服务器之一,它提供了多种工作模式,包括 Prefork、Worker 和 Event 等。其中,Worker 工作模式是 Apache 2.x 版本中...
在这个"zookeeper实战:SingleWorker代码样例"中,我们将深入探讨如何使用ZooKeeper实现一个简单的SingleWorker模式,以及涉及的相关源码和工具。 首先,SingleWorker模式是ZooKeeper中常见的应用场景之一,常用于...
一、源码描述 ...其中一对一是简单队列模式,一对多是Worker模式,而发布订阅包括发布订阅模式,路由模式和通配符模式 三、注意事项 1、开发环境为Visual Studio 2019,无数据库,使用.net 开发。
Master Worker模式的核心思想是将一个大任务分解为许多小任务,由一个主进程(Master)分配给多个工作进程(Worker)。Master负责任务的调度、监控和协调,而Worker则专注于执行具体的任务。在Java中,我们可以使用...
一、源码描述 ...其中一对一是简单队列模式,一对多是Worker模式,而发布订阅包括发布订阅模式,路由模式和通配符模式 三、注意事项 1、开发环境为Visual Studio 2019,无数据库,使用.net 开发。
在J2EE模式中,MVC常常与其他模式如Service-to-Worker模式结合,Struts框架就是实现MVC模式的一个例子,它提供了Controller和View的部分,而Model则需要开发者自定义实现。 **MVC设计思想** - **模型(Model)**:...
为了应对这个问题,Node.js内置了一个cluster模块,它允许我们以master-worker模式启动多个Node.js应用实例,从而充分利用多核CPU资源,并实现高可用性和负载均衡。 cluster模块的核心功能是创建一个master进程和多...
Apache支持多种工作模式来适应不同场景的需求,其中主要的工作模式包括Prefork模式与Worker模式。 1. **Prefork模式**: - **特点**: - **多进程**:每个客户端请求都会创建一个新的进程来处理,这确保了服务器...
本篇内部资料主要围绕Node.js的进程管理,特别是Master-Worker模式和进程间通信(IPC)进行详细讲解。 首先,进程管理服务模型经历了多个阶段。从同步到复制进程,再到多线程,直至现在的事件驱动多进程架构。Node....
在生产环境中,通常使用master-worker模式,因为它具有更高的稳定性和性能优化。在该模式下,一个master进程负责管理多个worker进程,接收和分发来自客户端的请求。worker进程执行实际的HTTP请求处理,提供服务。...