java线程池代码_java线程池代码package com.thread;
import java.util.LinkedList;
//线程池
public class ThreadPool extends ThreadGroup {
private boolean isClosed = false; // 线程池是否关闭
private LinkedList workQueue; // ⼯作队列
private final static int threadPoolID = 1; // 线程池的id
public ThreadPool(int poolSize) { // poolSize 表⽰线程池中的⼯作线程的数量
super(threadPoolID + ""); // 指定ThreadGroup的名称
java线程池创建的四种setDaemon(true); // 继承到的⽅法，设置是否守护线程池
workQueue = new LinkedList(); // 创建⼯作队列
for (int i = 0; i < poolSize; i++) {
new WorkThread(i).start(); // 创建并启动⼯作线程，线程池数量是多少就创建多少个⼯作线程
}
}
/** 向⼯作队列中加⼊⼀个新任务，由⼯作线程去执⾏该任务 */
public synchronized void execute(Runnable task) {
if (isClosed) {
throw new IllegalStateException();
}
if (task != null) {
workQueue.add(task);// 向队列中加⼊⼀个任务
notify(); // 唤醒⼀个正在getTask()⽅法中待任务的⼯作线程
}
}
/** 从⼯作队列中取出⼀个任务,⼯作线程会调⽤此⽅法 */
private synchronized Runnable getTask(int threadid)
throws InterruptedException {
while (workQueue.size() == 0) {
if (isClosed)
return null;
System.out.println("⼯作线程" + threadid + "等待任务...");
wait(); // 如果⼯作队列中没有任务，就等待任务
}
System.out.println("⼯作线程" + threadid + "开始执⾏任务...");
return (Runnable) veFirst(); // 反回队列中第⼀个元素，并从队列中删除
}
/** 关闭线程池 */
public synchronized void closePool() {
if (!isClosed) {
waitFinish(); // 等待⼯作线程执⾏完毕
isClosed = true;
workQueue.clear(); // 清空⼯作队列
interrupt(); // 中断线程池中的所有的⼯作线程，此⽅法继承⾃ThreadGroup类
}
}
/** 等待⼯作线程把所有任务执⾏完毕 */
public void waitFinish() {
synchronized (this) {
isClosed = true;
notifyAll(); // 唤醒所有还在getTask()⽅法中等待任务的⼯作线程
}
Thread[] threads = new Thread[activeCount()]; // activeCount()
// 返回该线程组中活动线程的估计值。
int count = enumerate(threads); // enumerate()⽅法继承⾃ThreadGroup类，根据活动线程的估计值获得线程组中当前所有活动的⼯作线程
for (int i = 0; i < count; i++) { // 等待所有⼯作线程结束
try {
threads[i].join(); // 等待⼯作线程结束
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
}
/**
* 内部类,⼯作线程，负责从⼯作队列中取出任务，并执⾏
*/
private class WorkThread extends Thread {
private int id;
public WorkThread(int id) {
// ⽗类构造⽅法，将线程加⼊到当前ThreadPool线程组中
super(ThreadPool.this, id + "");
this.id = id;
}
public void run() {
while (!isInterrupted()) { // isInterrupted()⽅法继承⾃Thread类，判断线程是否被中断Runnable task = null;
try {
task = getTask(id); // 取出任务
} catch (InterruptedException ex) {
ex.printStackTrace();
}
// 如果getTask()返回null或者线程执⾏getTask()时被中断，则结束此线程
if (task == null)
return;
try {
task.run(); // 运⾏任务
} catch (Throwable t) {
t.printStackTrace();
}
}
}
}
public static void main(String[] args) throws InterruptedException {
ThreadPool threadPool = new ThreadPool(3); // 创建⼀个有个3⼯作线程的线程池Thread.sleep(500); // 休眠500毫秒，以便让线程池中的⼯作线程全部运⾏
// 运⾏任务
for (int i = 0; i <= 5; i++) { // 创建6个任务
}
threadPool.waitFinish(); // 等待所有任务执⾏完毕
threadPool.closePool(); // 关闭线程池
}
private static Runnable createTask(final int taskID) { return new Runnable() {
public void run() {
// System.out.println("Task" + taskID + "开始"); System.out.println("Hello world");
// System.out.println("Task" + taskID + "结束");
}
};
}
}

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。