java创建线程池（java创建线程池的几种方式）

本篇文章给大家谈谈java创建线程池，以及java创建线程池的几种方式对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、java线程池（一） 简述线程池的几种使用方式
• 2、java for循环中创建线程池
• 3、JAVA 线程池使用
• 4、java如何创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。求代码
• 5、线程池的创建

java线程池（一） 简述线程池的几种使用方式

首先说明下java线程是如何实现线程重用的

1. 线程执行完一个Runnable的run()方法后，不会被杀死

2. 当线程被重用时，这个线程会进入新Runnable对姿盯象的run()方法12

java线程池由Executors提供的几种静态方法创建线程池。下面通过代码片段简单介绍下线程池的几种实现方式。后续会针对每敏拿个实现方式做详细的说明

newFixedThreadPool

创建一个固定大小的线程池

添加的任务达到线程池的容量之后开始加入任务队列开始线程重用总共开启线程个数跟指定容量相同。

@Test

public void newFixedThreadPool() throws Exception {

ExecutorService executorService = Executors.newFixedThreadPool(1);

executorService = Executors.newFixedThreadPool(1, new ThreadFactoryBuilder().build());

RunThread run1 = new RunThread("run 1");

executorService.execute(run1);

executorService.shutdown();

}12345678

newSingleThreadExecutor

仅支持单线程顺序处理任务

@Test

public void newSingleThreadExecutor() throws Exception {

ExecutorService executorService = Executors.newSingleThreadExecutor();

executorService = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().build());

executorService.execute(new RunThread("run 1"));

executorService.execute(new RunThread("run 2"));

executorService.shutdown();

}123456789

newCachedThreadPool

这种情况跟第一种的方式类似，不同的是这种情况线程池容量上线是Integer.MAX_VALUE 并且线程池开启缓存60s

@Test

public void newCachedThreadPool() throws Exception {

ExecutorService executorService = Executors.newCachedThreadPool();

executorService = Executors.newCachedThreadPool(new ThreadFactoryBuilder().build());

executorService.execute(new RunThread("run 1"));

executorService.execute(new RunThread("run 2"));

executorService.shutdown();

}123456789

newWorkStealingPool

支持给定的并行级别，并且可以使用多个队列来减少争用。

@Test

public void newWorkStealingPool() throws Exception {

ExecutorService executorService = Executors.newWorkStealingPool();

executorService = Executors.newWorkStealingPool(1);

RunThread run1 = new RunThread("run 1");

executorService.execute(run1);

executorService.shutdown();

}123456789

newScheduledThreadPool

看到迹拿和的现象和第一种相同，也是在线程池满之前是新建线程，然后开始进入任务队列，进行线程重用

支持定时周期执行任务(还没有看完)

@Test

public void newScheduledThreadPool() throws Exception {

ExecutorService executorService = Executors.newScheduledThreadPool(1);

executorService = Executors.newScheduledThreadPool(1, new ThreadFactoryBuilder().build());

executorService.execute(new RunThread("run 1"));

executorService.execute(new RunThread("run 2"));

executorService.shutdown();

}

[img]

java for循环中创建线程池

首先要明确线程池的意思，就是线程预先创建好放在一个池里态态面，使用后不会销毁

要区分任务和线程池，任务可以不断添加，但是线程池里线程的个数是固定的，当任务数超过线程数后，后面的任务需要等待有空闲的线程才会执行

所以不断添加任务没有关系，如果池中指野有50个线程，你添加100个任务同一时间也只会执行50个帆逗源任务，剩下的50个任务需要等待前面的任务执行完毕后继续执行

所以你的主线程原则上可以不断for，但是你总得有个结束点吧

JAVA 线程池使用

package tender nmem eris drawexpert service impl;

import java util List;

import ncurrent ExecutorService;

import ncurrent Executors;

import llections map ListOrderedMap;

/**

　吵扰　* 类 线程池类 控制程序线程实改销例个数 并实例线程

* @author yangtb

* 时间 / /

*

*/

public class ThreadPool {

private ExecutorService exe=null;//线程池

public ThreadPool(int pool_size)

{

exe=Executors newFixedThreadPool(pool_size);//创建线程池

System out println( the server is ready );

}

/**

* 运行循环实例线程 根据要实例的线程个数 传入条件ID

* @param worknum

*/

public  void server(int worknum String id)

{

int i= ;

while(iworknum)

{

//实例指定升歼旦个线程

WorkerThreadImpl t =  new WorkerThreadImpl(id);

exe execute(t);//放入线程池

i++;

}

}

lishixinzhi/Article/program/Java/hx/201311/26215

java如何创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。求代码

package test; 

import java.util.concurrent.ExecutorService; 

import java.util.concurrent.Executors; 

public class ThreadPoolExecutorTest { 

public static void main(String[] args) { 

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3); 

for (int i 首饥= 0; i  10; i++) { 

final int index = i; 

fixedThreadPool.execute(new Runnable() { 

public void run() { 

try { 

System.out.println(index); 

Thread.sleep(2000); 

} catch (InterruptedException e) { 

e.printStackTrace(); 

} 

} 

}); 

} 

} 

}

因为线程池大小为3，每个冲芹弯任务输出index后sleep 2秒，所以每两秒打印3个数字。

定长线程池的大小最好根据系统资源散闷进行设置。如Runtime.getRuntime().availableProcessors()

线程池的创建

new ThreadPoolExecutor(corePoolSize, maxinumPoolSize, keepAliveTime, milliseconds, runnableTaskQueue, handler);

参数简介：

当提交一个任务到线程池时，线程池会创建一个线程来执行任务，即使其它空闲的基本线程能够执行新任务也会创建线程，等到需要执行的任务数大于线程池基本大小时就不会再创建。如果调用了线程池的prestartAllCoreThreads()方法，线程池会提前创建并启动所有基本线程。

用于保存等待执行的任务的阻塞队列，可以有以下选择：

ArrayBlockingQueue ：是一个基于数组结构的有界阻塞耐仿毕队列，此队列按FIFO（先进先出）原则对元素进行排序

LinkedBlockingQueue ：一个基于链表结构的阻塞队列，此队列按FIFO排序元素，吞吐量通常高于ArrayBlockingQueue。静态工厂方大拦法Executors.newFixedThreadPool()使用了这个队列。

SynchronousQueue ：一个不存储元素的阻塞队列。每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态。吞吐量通常要高于LinkedBlockingQueue，静态工厂方法Executors.newCachedThreadPool()使用了这个昌芹队列。

PriorityBlockingQueue ：一个具有优先级的无限阻塞队列

线程池被允许创建的最大线程数，如果队列满了，并且已创建的线程数小于最大线程数，则线程池会再创建新的线程执行任务。需要注意的是，如果使用了无界的阻塞队列，那么这个参数也就没什么效果。

当队列和线程池都满了，说明线程池处于饱和状态，那么必须采取一种策略处理提交的新任务。默认情况下是AbortPolicy，表示无法处理新任务时抛出异常。在JDK1.5中Java线程池框架提供了以下4中策略。

AbortPolicy ：直接抛出异常

CallerRunsPolicy ：只用调用者所在线程来运行任务

DiscardOldestPolicy ：丢弃队列里最近的一个任务，并执行当前任务

DiscardPolicy ：不处理，丢弃掉

线程池的工作线程空闲后，保持存活的时间。所以如果任务很多，每个任务执行的时间比较短，可以调大时间，提高线程的利用率

可选单位有天（DAYS）、小时（HOURS）、分钟（MINUTES）、毫秒（MILLISECONDS）、微秒（MICROSECONDS，千分之一毫秒）、纳秒（NANOSECONDS，千分之一微秒）

关于java创建线程池和java创建线程池的几种方式的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。