executorservice等待线程池执行完毕_java线程池策略

executorservice等待线程池执行完毕_java线程池策略packagecom.aop8.testJava;importjava.util.ArrayList;importjava.util.List;importjava.util.concurrent.Callable;importjava.util.concurrent.ExecutionException;importjava.util.concurrent.Executo…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

一、Executor 线程池的体系UML图:

在这里插入图片描述

二、Executor 、ExecutorService 、ThreadPoolExecutor 等类的说明

1、线程池: 提供一个线程队列,队列中保存着所有等待状态的线程。避免了创建与销毁的额外开销,提高了响应的速度。

2、线程池的体系结构:
java.util.concurrent.Executor 负责线程的使用和调度的根接口
		|--ExecutorService 子接口: 线程池的主要接口
				|--ThreadPoolExecutor 线程池的实现类
				|--ScheduledExceutorService 子接口: 负责线程的调度
					|--ScheduledThreadPoolExecutor : 继承ThreadPoolExecutor,实现了ScheduledExecutorService
			

3、工具类 : Executors
ExecutorService newFixedThreadPool() : 创建固定大小的线程池
ExecutorService newCachedThreadPool() : 缓存线程池,线程池的数量不固定,可以根据需求自动的更改数量。
ExecutorService newSingleThreadExecutor() : 创建单个线程池。 线程池中只有一个线程

ScheduledExecutorService newScheduledThreadPool() : 创建固定大小的线程,可以延迟或定时的执行任务

三、代码示例:

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class TestThreadPool { 
   

	public static void main(String[] args) throws InterruptedException, ExecutionException { 
   
		//1. 创建线程池
		ExecutorService pool = Executors.newFixedThreadPool(5);
		
		List<Future<Integer>> list=new ArrayList<Future<Integer>>();
		
		for (int i = 0; i < 10; i++) { 
   
			Future<Integer>  future=pool.submit(new Callable<Integer>() { 
   
				public Integer call() throws Exception { 
   
					int sum=0;
					for (int i = 0; i <=100; i++) { 
   
						sum+=i;
					}
					return sum;
				}
			});
			list.add(future);
		}
		
		pool.shutdown();
		
		for (Future<Integer> future : list) { 
   
			System.out.println(future.get());
		}		
		
// Future<Integer> future=pool.submit(new Callable<Integer>() { 
   
// public Integer call() throws Exception { 
   
// int sum=0;
// for (int i = 0; i <=100; i++) { 
   
// sum+=i;
// }
// return sum;
// }
// });
// System.out.println(future.get());
// pool.shutdown(); 
		
		
// ThreadPoolDemo threadPoolDemo=new ThreadPoolDemo();
// 
// //2. 为线程池中的线程分配任务
// for (int i = 0; i < 10; i++) { 
   
// pool.submit(threadPoolDemo);
// }
// 
// //3. 关闭线程池
// pool.shutdown();
// 
		
// new Thread(threadPoolDemo).start();
// new Thread(threadPoolDemo).start();
		
	}
}

class ThreadPoolDemo implements Runnable{ 
   

	private int i=0;
	
	public void run() { 
   
		while(i<=100){ 
   
			System.out.println(Thread.currentThread().getName()+" "+ i++);
		}
	}	
}
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195161.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • Qt QFile按行读写数据

    Qt QFile按行读写数据1.包含的头文件#include<QDebug>#include<QFile>2.读数据QFilefile(“inputFile.txt”);if(file.open(QIODevice::ReadOnly|QIODevice::Text)){while(!file.atEnd()){QByt…

  • 人工智能:智能优化算法

    人工智能:智能优化算法**人工智能:智能优化算法优化问题是指在满足一定条件下,在众多方案或参数值中寻找最优方案或参数值,以使得某个或多个功能指标达到最优,或使系统的某些性能指标达到最大值或最小值。优化问题广泛地存在于信号处理、图像处理、生产调度、任务分配、模式识别、自动控制和机械设计等众多领域。优化方法是一种以数学为基础,用于求解各种优化问题的应用技术。各种优化方法在上述领域得到了广泛应用,并且已经产生了巨大的经济效益和社会效益。实践证明,通过优化方法,能够提高系统效率,降低能耗,合理地利用资源,并且随着处理对象规模的增加

  • hadoop错误_wired connected

    hadoop错误_wired connectedhadoop错误INFO ipc.Client Retrying connect to server

  • 大数据采集技术概述

    大数据采集技术概述大数据采集是指从传感器和智能设备、企业在线系统、企业离线系统、社交网络和互联网平台等获取数据的过程。数据包括RFID数据、传感器数据、用户行为数据、社交网络交互数据及移动互联网数据等各种类型的结构化、半结构化及非结构化的海量数据。不但数据源的种类多,数据的类型繁杂,数据量大,并且产生的速度快,传统的数据采集方法完全无法胜任。所以,大数据采集技术面临着许多技术挑战,一方面需要保证数据…

  • 手把手教你如何微信公众号开发「建议收藏」

    手把手教你如何微信公众号开发「建议收藏」   最近的话,发现微信开发其实也有很多挺有意思的地方,比如最近很火的一款游戏“跳一跳”,也让我如此着迷。。但是,今天我所要讲的并不是对于小程序的开发,而是要说一下,关于微信开发的另外一个内容,那就是微信公众号。。  关于,什么是微信公众号,微信公众号怎么申请,这个我就不多说,这些基本的概念不在这里进行讲解,自己可以直接百度就可以找到很多的资源。而我主要讲解一下关于微信公众号开发中,一…

  • clickhouse 正则_socket获取本机ip地址

    clickhouse 正则_socket获取本机ip地址去掉内网的SQL查询SELECTdate,ts,domain,count(1)astotalFROMdb.tbWHEREdate=today()AND(replaceRegexpAll(_pingip,’^(127\\.0\\.0\\.1)|(localhost)|(10\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3})|(172\\.((1[6-…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号