java编程实战

线程池为什么要有它:

线程创建要开辟虚拟机栈,释放线程要垃圾回收的。

server端要并发访问数据库的。

服务器启动有线程池放着。

-----

线程池的概念:

1.任务队列

2.拒绝策略(抛出异常,直接丢弃,阻塞,放在临时队列)

3.初始化值init(min),初始线程池大小

3.active

5.max线程池线程的最大个数

min<=active<=max

quartz:定时任务

代码:

package chapter13;

import java.util.ArrayList;

import java.util.LinkedList;

import java.util.List;

public class SimpleThreadPoolMy {

private final int size;

private final static int DEFAULT_SIZE = 10;

private static volatile int seq = 0;

private final static String THREAD_PREFIX = "SIMPLE_THREAD_POOL-";

private final static ThreadGroup GROUP = new ThreadGroup("Pool_Group");

private final static List<WorkerTask> THREAD_QUEUE = new ArrayList<>();

/**

* task queue

*/

private final static LinkedList<Runnable> TASK_QUEUE = new LinkedList<>();

public SimpleThreadPoolMy() {

this(DEFAULT_SIZE);

}

public SimpleThreadPoolMy(int size) {

this.size = size;

init();

}

private void init() {

for (int i = 0; i < size; i++) {

createWorkTask();

}

}

private void createWorkTask() {

WorkerTask task = new WorkerTask(GROUP, THREAD_PREFIX + (seq++));

task.start();

THREAD_QUEUE.add(task);

}

private enum TaskState {

FREE, RUNNING, BLOCKEED, DEAD

}

public void submit(Runnable runnable) {

synchronized (TASK_QUEUE) {//别的方法有读的操作,这里有写的操作,所以你要加锁的

TASK_QUEUE.addLast(runnable);

TASK_QUEUE.notifyAll();

}

}

/**

* Thread in ThreadPool

*/

private static class WorkerTask extends Thread {//为什么定义为private呢就是为了不想让别人知道我是什么

private volatile TaskState taskState = TaskState.FREE;

public WorkerTask(ThreadGroup group, String name) {//构造方法,调用了Thread的构造

super(group, name);

}

public TaskState getTaskState() {

return this.taskState;

}

public void close() {

this.taskState = TaskState.DEAD;

}

public void run() {//重写外汇返佣保证执行完之后不能挂掉

OUTER:

while (this.taskState != TaskState.DEAD) {//当前的线程没有死掉

Runnable runnable;

synchronized (TASK_QUEUE) {//去任务队列调取任务

while (TASK_QUEUE.isEmpty()) {

try {

taskState = TaskState.BLOCKEED;

TASK_QUEUE.wait();//没有任务就释放锁,这个线程在TASK_QUEUE上等待 wait会被打断  打断的话就break出来

} catch (InterruptedException e) {

break OUTER;//https://blog.csdn.net/zhaoheng2017/article/details/78385973  被打断了就接着去调取任务

}

}

runnable = TASK_QUEUE.removeFirst();//队列 先进先出 任务队列只被消费一次 比如数据库线程池,取出来我执行连接就可以了

}

if (runnable != null) {

taskState = TaskState.RUNNING;

runnable.run();

taskState = TaskState.FREE;

}

}

}

}

}

原文链接:https://blog.csdn.net/qq_28764557/article/details/103575987

原文地址:https://www.cnblogs.com/benming/p/12066934.html

时间: 2024-08-30 15:13:11

java编程实战的相关文章

Java编程实战宝典PDF (中文版带书签)

Java编程实战宝典PDF 目录 第1篇 Java基础知识入门第1章 Java的开发运行环境( 教学视频:57分钟)1.1 Java运行原理与Java虚拟机1.1.1 Java运行原理简述1.1.2 Java虚拟机1.2 Java的开发环境1.2.1 JDK的安装1.2.2 如何设置系统环境变量1.2.3 JDK安装后的测试与验证1.2.4 编译命令的使用1.2.5 解释执行命令的使用1.2.6 UltraEdit的使用1.3 Java应用程序示例1.4 Java Applet程序示例1.5 本

redis3.0 集群实战3 - java编程实战

本文主要描述使用jedis进行redis-cluster操作 jedis jedis是redis官方推荐使用的java redis客户端,github地址为,https://github.com/xetorthio/jedis,本文使用jedis进行redis集群的操作. jedis从2.3.0版本后开始支持redis cluster,不过看官方的released文档(https://github.com/xetorthio/jedis/releases)在2.3.0版本后的每个版本都会修复一些

java并发编程实战学习(3)--基础构建模块

转自:java并发编程实战 5.3阻塞队列和生产者-消费者模式 BlockingQueue阻塞队列提供可阻塞的put和take方法,以及支持定时的offer和poll方法.如果队列已经满了,那么put方法将阻塞直到空间可用:如果队列为空,那么take方法将阻塞直到有元素可用.队列可以是有界的也可以是无界的. 如果生产者生成工作的速率比消费者处理工作的速率款,那么工作项会在队列中累计起来,最终好紧内存.同样,put方法的阻塞特性也极大地简化了生产者的编码.如果使用有界队列,当队列充满时,生产者将阻

《java并发编程实战》笔记(一)

最近在看<java并发编程实战>,希望自己有毅力把它读完. 线程本身有很多优势,比如可以发挥多处理器的强大能力.建模更加简单.简化异步事件的处理.使用户界面的相应更加灵敏,但是更多的需要程序猿面对的是安全性问题.看下面例子: public class UnsafeSequence { private int value; /*返回一个唯一的数值*/ public int getNext(){ return value++; } } UnsafeSequence的问题在于,如果执行时机不对,那么

《Java并发编程实战》第十六章 Java内存模型 读书笔记

Java内存模型是保障多线程安全的根基,这里仅仅是认识型的理解总结并未深入研究. 一.什么是内存模型,为什么需要它 Java内存模型(Java Memory Model)并发相关的安全发布,同步策略的规范.一致性等都来自于JMM. 1 平台的内存模型 在架构定义的内存模型中将告诉应用程序可以从内存系统中获得怎样的保证,此外还定义了一些特殊的指令(称为内存栅栏或栅栏),当需要共享数据时,这些指令就能实现额外的存储协调保证. JVM通过在适当的位置上插入内存栅栏来屏蔽在JVM与底层平台内存模型之间的

《Java并发编程实战》第八章 线程池的使用 读书笔记

一.在任务与执行策略之间的隐性解耦 有些类型的任务需要明确地指定执行策略,包括: . 依赖性任务.依赖关系对执行策略造成约束,需要注意活跃性问题.要求线程池足够大,确保任务都能放入. . 使用线程封闭机制的任务.需要串行执行. . 对响应时间敏感的任务. . 使用ThreadLocal的任务. 1. 线程饥饿死锁 线程池中如果所有正在执行任务的线程都由于等待其他仍处于工作队列中的任务而阻塞,这种现象称为线程饥饿死锁. 2. 运行时间较长的任务 Java提供了限时版本与无限时版本.例如Thread

《Java并发编程实战》第十一章 性能与可伸缩性 读书笔记

造成开销的操作包括: 1. 线程之间的协调(例如:锁.触发信号以及内存同步等) 2. 增加的上下文切换 3. 线程的创建和销毁 4. 线程的调度 一.对性能的思考 1 性能与可伸缩性 运行速度涉及以下两个指标: 某个指定的任务单元需要"多快"才能处理完成.计算资源一定的情况下,能完成"多少"工作. 可伸缩性: 当增加计算资源时(例如:CPU.内存.存储容器或I/O带宽),程序的吞吐量或者处理能力能相应地增加. 2 评估各种性能权衡因素 避免不成熟的优化.首先使程序正

【Java并发编程实战】—– AQS(四):CLH同步队列

在[Java并发编程实战]-–"J.U.C":CLH队列锁提过,AQS里面的CLH队列是CLH同步锁的一种变形. 其主要从双方面进行了改造:节点的结构与节点等待机制.在结构上引入了头结点和尾节点,他们分别指向队列的头和尾,尝试获取锁.入队列.释放锁等实现都与头尾节点相关.而且每一个节点都引入前驱节点和后兴许节点的引用:在等待机制上由原来的自旋改成堵塞唤醒. 其结构例如以下: 知道其结构了,我们再看看他的实现.在线程获取锁时会调用AQS的acquire()方法.该方法第一次尝试获取锁假设

【Java并发编程实战】—– AQS(三):阻塞、唤醒:LockSupport

在上篇博客([Java并发编程实战]-– AQS(二):获取锁.释放锁)中提到,当一个线程加入到CLH队列中时,如果不是头节点是需要判断该节点是否需要挂起:在释放锁后,需要唤醒该线程的继任节点 lock方法,在调用acquireQueued(): if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) interrupted = true; 在acquireQueued()中调用parkAndCheckIn