java ExecutorService使用方法详解_java

下面的例子主要讨论两个问题:
问题1.线程池固定大小,假设为5.那么向线程池放入10个线程,运行效果如何?其他线程的状态?
问题2.那么如何从线程池中移除某一个线程,确切说是使某一个线程成为空闲线程?

例子:

package com.dada.executorService; 

import java.util.concurrent.TimeUnit; 

public class JobThread extends Thread { 

 // 为线程命名
 public JobThread(String name,long threadId) {
  super(name);
 } 

 @Override
 public void run() {
  // 如果主线程包含这个线程就一直运行
  while (MainThread.threadNameMap.containsKey(this.getName())) {
   try {
    System.out.println("线程名称:-----" + this.getName());
    TimeUnit.SECONDS.sleep(4);
   } catch (Exception e) {
    e.printStackTrace();
   }
  }
  System.out.println("***************线程结束,线程名称:*********" + this.getName());
 }
}
package com.dada.executorService; 

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit; 

public class MainThread {
 public static final int THREADPOOL_SIZE = 5;
 // 生成固定大小的线程池
 public static ExecutorService exec = Executors.newFixedThreadPool(THREADPOOL_SIZE);
 // 用来存储线程名称的map
 public static Map<String, String> threadNameMap = new HashMap<String, String>(); 

 public static void main(String[] args) {
  // 向线程池中插入 10 个线程,但是线程池只允许最大 5 个线程,所以其他 5 个线程等待中
  for (int i = 0; i < THREADPOOL_SIZE + 5; i++) {
   String threadName = getThreadName(i);
   threadNameMap.put(threadName, threadName);
   exec.execute(new JobThread(threadName, i));
  } 

  System.out.println("Hash表的Size:" + threadNameMap.size()); 

  try {
   System.out.println("主线程睡一会!");
   TimeUnit.SECONDS.sleep(3);
  } catch (Exception e) {
   e.printStackTrace();
   System.out.println("醒了!");
  } 

    // 下面的这几个用来删除线程池里面的线程
  //removeThread(0);
  //removeThread(1);
  //removeThread(2);
 } 

 public static void removeThread(int i) {
  threadNameMap.remove(getThreadName(i));
  System.out.println("删除线程Thread" + i + ", Hash表的Size:" + threadNameMap.size());
 } 

 public static String getThreadName(int i) {
  return "threadname"+i;
 } 

} 

直接运行代码结果:

线程名称:-----threadname0
Hash表的Size:10
主线程睡一会!
线程名称:-----threadname2
线程名称:-----threadname4
线程名称:-----threadname1
线程名称:-----threadname3
线程名称:-----threadname4
线程名称:-----threadname2
线程名称:-----threadname3
线程名称:-----threadname1
线程名称:-----threadname0
线程名称:-----threadname1
线程名称:-----threadname3
线程名称:-----threadname0
线程名称:-----threadname4
线程名称:-----threadname2
线程名称:-----threadname1
线程名称:-----threadname3
线程名称:-----threadname4

结论:
发现打印的:线程名称一直从threadname0到threadname4,没有其他的名称。
由此证明:向线程池中放入10个线程,但是线程池的大小为5,只能给5个线程分配CPU,运行的就是最先放入线程池中的5个线程,其他线程都处于就绪状态(阻塞状态)。

去掉注释之后代码运行结果:

线程名称:-----threadname0
线程名称:-----threadname2
线程名称:-----threadname4
Hash表的Size:10
主线程睡一会!
线程名称:-----threadname1
线程名称:-----threadname3
删除线程Thread0, Hash表的Size:9
删除线程Thread1, Hash表的Size:8
删除线程Thread2, Hash表的Size:7
***************线程结束,线程名称:*********threadname2
***************线程结束,线程名称:*********threadname0
线程名称:-----threadname5
线程名称:-----threadname6
***************线程结束,线程名称:*********threadname1
线程名称:-----threadname4
线程名称:-----threadname7
线程名称:-----threadname3
线程名称:-----threadname6
线程名称:-----threadname5
线程名称:-----threadname7
线程名称:-----threadname4
线程名称:-----threadname3
线程名称:-----threadname5
线程名称:-----threadname6
线程名称:-----threadname7
线程名称:-----threadname4
线程名称:-----threadname3

结论:
从结果中可以看出,在移除线程之前,运行的线程还是从thread0到thread4。当移除线程thread0后,新的线程thread3开始运行,而且是按照顺序到threadname7。

总结如下:

1.线程池固定大小,假设为5.那么向线程池放入10个线程,运行效果如何?其他线程的状态?
a.线程池的概念就是你不断的向其中push请求,但是它只能处理规定额度的线程,多余的线程都会在其中等待。
b.当其中一个线程处理完毕(业务执行完毕或退出while循环),线程池就会自动从等待的队列中取出一个作业,使用空闲的线程来运行这个作业。运行线程池中的哪个,从例子上来看应该是按照被放入的先后顺序来的。 

2.那么如何从线程池中移除某一个线程,确切说是使某一个线程成为空闲线程?
线程池无法获取其中某一个线程并杀掉他,因为使用线程池的主线程和主线程开启的线程是平级的,谁都无权主宰另一方的存亡。但是可以换一个方式,委婉的达到目的。
a.主线程维护一个Hash表可以是一个HashMap。key值任意,但是要唯一,可以唯一标示一个线程。
b.所有放入线程池的线程,都要生成一个key值,然后存入这个HashMap中。
c.对于循环类的线程,如while(true)的线程。需要增加一个条件,每一轮循环校验这个线程的key是否存在于上面HashMap中。如果不存在则退出while循环。
d.虽然主线程不可以主宰其他线程的存亡,但是可以对自己的HashMap进行put或是remove操作。到此,只要从HashMap中移除线程对应的Key值,这个线程在下次循环的时候就会自动退出了。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

以上是小编为您精心准备的的内容,在的博客、问答、公众号、人物、课程等栏目也有的相关内容,欢迎继续使用右上角搜索按钮进行搜索java
ExecutorService
executorservice详解、java executorservice、executorservice、executorservice 阻塞、executorservice用法,以便于您获取更多的相关知识。

时间: 2024-11-08 23:28:55

java ExecutorService使用方法详解_java的相关文章

Java模糊查询方法详解_java

当我们需要开发一个方法用来查询数据库的时候,往往会遇到这样一个问题:就是不知道用户到底会输入什么条件,那么怎么样处理sql语句才能让我们开发的方法不管接受到什么样的条件都可以正常工作呢?这时where '1'='1'加上list就可以完美解决这个问题了,废话少说,上代码: // 模糊查询方法 public List<person> query() { List<person> list = new ArrayList<>(); Connection con = null

JAVA hashCode使用方法详解_java

一.问题引入谈到hashCode就不得不说equals方法,二者均在Object类里,由于Object类是所有类的基类,所以一切类里都可以重写这两个方法.要想较清晰的理解,需要先知道容器Collection,Set,list,Map(key值不可重复),Set元素无序不重复,list元素有序可重复,那么JVM是如何确定不同的元素的呢?难道是逐个比较么,那样效率就太低了,JVM采用hash的方法(hash地址不一定是实际的物理地址),看看这个地址上是否有内容,没的话就认为不存在相同对象-- 且看下

Java ArrayDeque使用方法详解_java

题目要求为: 卡拉兹(Callatz)猜想: 对任何一个自然数n,如果它是偶数,那么把它砍掉一半:如果它是奇数,那么把(3n+1)砍掉一半.这样一直反复砍下去,最后一定在某一步得到n=1.当我们验证卡拉兹猜想的时候,为了避免重复计算,可以记录下递推过程中遇到的每一个数.例如对n=3进行验证的时候,我们需要计算3.5.8.4.2.1,则当我们对n=5.8.4.2进行验证的时候,就可以直接判定卡拉兹猜想的真伪,而不需要重复计算,因为这4个数已经在验证3的时候遇到过了,我们称5.8.4.2是被3"覆盖

Java Spring MVC 上传下载文件配置及controller方法详解_java

下载: 1.在spring-mvc中配置(用于100M以下的文件下载) <bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter"> <property name="messageConverters"> <list> <!--配置下载返回类型--> <bean class="or

java中set接口使用方法详解_java

java中的set接口有如下的特点: 不允许出现重复元素: 集合中的元素位置无顺序: 有且只有一个值为null的元素. 因为java中的set接口模仿了数学上的set抽象,所以,对应的数学上set的特性为: 互异性:一个集合中,任何两个元素都认为是不相同的,即每个元素只能出现一次.无序性:一个集合中,每个元素的地位都是相同的,元素之间是无序的.集合上可以定义序关系,定义了序关系后,元素之间就可以按照序关系排序.但就集合本身的特性而言,元素之间没有必然的序.空集的性质:空集是一切集合的子集    

Java的JSON处理器fastjson使用方法详解_java

fastjson 是一个性能很好的 Java 语言实现的 JSON 解析器和生成器,来自阿里巴巴的工程师开发. 主要特点: • 快速FAST (比其它任何基于Java的解析器和生成器更快,包括jackson) • 强大(支持普通JDK类包括任意Java Bean Class.Collection.Map.Date或enum) • 零依赖(没有依赖其它任何类库除了JDK) 示例代码: import com.alibaba.fastjson.JSON; Group group = new Group

Java的枚举类型使用方法详解_java

1.背景在java语言中还没有引入枚举类型之前,表示枚举类型的常用模式是声明一组具有int常量.之前我们通常利用public final static 方法定义的代码如下,分别用1 表示春天,2表示夏天,3表示秋天,4表示冬天. public class Season { public static final int SPRING = 1; public static final int SUMMER = 2; public static final int AUTUMN = 3; publi

Java解析XML格式数据的方法详解_java

最初,XML 语言仅仅是意图用来作为 HTML 语言的替代品而出现的,但是随着该语言的不断发展和完善,人们越来越发现它所具有的优点:例如标记语言可扩展,严格的语法规定,可使用有意义的标记,内容存储和表现分离等等优势注定了该语言从诞生之日起就会走向辉煌. XML 语言在成为 W3C 标准之后进入到了一个快速发展的时期,当然它本身所具有的一系列优点和优势也注定了各大技术厂商对它的偏爱,Java 作为软件行业的一种开发技术也迅速作出了反应,出现了多种对 XML 支持的工具,本文将会从这个角度对 Jav

Java RandomAccessFile的用法详解_java

RandomAccessFile RandomAccessFile是用来访问那些保存数据记录的文件的,你就可以用seek( )方法来访问记录,并进行读写了.这些记录的大小不必相同:但是其大小和位置必须是可知的.但是该类仅限于操作文件. RandomAccessFile不属于InputStream和OutputStream类系的.实际上,除了实现DataInput和 DataOutput接口之外(DataInputStream和DataOutputStream也实现了这两个接口),它和这两个类系毫