欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java ExecutorService使用方法详解

程序员文章站 2024-03-31 20:34:52
下面的例子主要讨论两个问题: 问题1.线程池固定大小,假设为5.那么向线程池放入10个线程,运行效果如何?其他线程的状态? 问题2.那么如何从线程池中移除某一个线程,确...

下面的例子主要讨论两个问题:
问题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值,这个线程在下次循环的时候就会自动退出了。

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