Executor

Java ~ Executor ~ ExecutorService【源码】

前言文章相关系列：《Java ~ Executor【目录】》（持续更新）相关系列：《Java ~ Executor ~ ExecutorService【源码】》（学习过程/多有漏误/仅作参考/不再更新）相关系列：《Java ~ Executor ~ Ex…

使用Java线程池ThreadPoolExecutor(Spring Boot微服务)

记录：475 场景：在Spring Boot微服务中使用Java线程池ThreadPoolExecutor。实现Runnable接口提交线程任务到线程池。版本：JDK 1.8,Spring Boot 2.6.3。 1.使用注解配置线程池ThreadPoolExecutor (1)说明 ThreadPoolExecutor，…

线程池一、executor接口和ExecutorService接口介绍

工作这么多年，很少有时间写博客，昨天和一个正在跳槽找工作的同学交流，他是做web的，面试的时候被问到了线程池一块的技术，被难住了！这让我不禁也想巩固下我这方便的基础了，天天在用的东西&#x…

Spark - Executor 初始化报警都进行1次

一.引言程序启动 M 个 Executor，每个 Executor 共 N core，即每个 Executor 上的 task N，现在有一个 object 需要在每一个 task 上初始化公用变量，有两个问题需要解决： A.该公用变量在 executor 上共用，…

Java并发编程：Executor框架

目录一、两级调度模型二、Executor框架的结构三、Executor框架中的成员四、Demos 我们都知道线程的创建与销毁需要一定的开销，如果每个任务都需要创建一个线程将会消耗大量的计算资源，JDK 5之后把工作单元和执行机制区分开了，工作单元…

Java ~ Collection/Executor ~ ArrayBlockingQueue【源码】

前言文中的源码注释/结论是我个人学习过程中的理解/看法，多有漏误，后期的新看法/总结也不会再于本文中修正/添加，因此本文内容只可作为参考/提示使用，最新看法/总结以总结篇为准，链接在本地底部。一 ArrayBlockingQ…

Java ~ Executor ~ ExecutorService【总结】

前言文章相关系列：《Java ~ Executor【目录】》（持续更新）相关系列：《Java ~ Executor ~ ExecutorService【源码】》（学习过程/多有漏误/仅作参考/不再更新）相关系列：《Java ~ Executor ~ Ex…

【线程池】ScheduledExecutorService接口和ScheduledThreadPoolExecutor定时任务线程池使用详解

目录〇、简介 0.1 ScheduledExecutorService 和 Timer 的区别一、什么是ScheduledExecutorService？ 二、ScheduledThreadPoolExecutor中的方法 2.1 构造方法 2.2 schedule方法 2.3 scheduleAtFixedRate方法 2.4 scheduleWithFixedDelay方法 2.5 setConti…

Java ~ Executor ~ AbstractExecutorService【总结】

前言文章相关系列：《Java ~ Executor【目录】》（持续更新）相关系列：《Java ~ Executor ~ AbstractExecutorService【源码】》（学习过程/多有漏误/仅作参考/不再更新）相关系列：《Java ~ Execu…

【线程池】线程池的拒绝策略（饱和策略）

目录一、总结二、拒绝策略源码分析 2.1 AbortPolicy 2.2 DiscardPolicy 2.3 DiscardOldestPolicy 2.4 CallerRunsPolicy 2.5 自定义三、执行拒绝策略一、总结如果当前同时运行的线程数量达到最大线程数量并且队列也已经被放满了任务时，ThreadPoolTaskE…

Java ~ Executor ~ Future【源码】

前言文章相关系列：《Java ~ Executor【目录】》（持续更新）相关系列：《Java ~ Executor ~ Future【源码】》（学习过程/多有漏误/仅作参考/不再更新）相关系列：《Java ~ Executor ~ Future【总结…

【调度工具】Azkaban用户手册

目录一、概述 1.1 Azkaban 是什么 1.2 Azkaban 特点 1.3 Azkaban 与 Oozie 对比功能工作流定义工作流传参定时执行资源管理工作流执行工作流管理 1.4 Azkaban 运行模式及架构 Azkaban 三大核心组件 Azkaban有两种部署方式 Azkaban Web Server Azkaban …

彻底理解Java并发：Java线程池

本篇内容包括：线程池概述、Java 线程池的几个重要参数、线程池的执行流程、拒绝策略以及线程池状态、Java 线程池的使用（常用的线程池、Executor 框架、ThreadPoolExecutor创建线程池、Executor 框架的继承关系）等内容。一、线程池概述池化…

java中创建线程的方式有哪些？

在 Java 中，有几种主要的方式来创建线程： 1. 继承 Thread 类： 通过继承 Thread 类，重写 run 方法来定义线程执行的逻辑。 class MyThread extends Thread {public void run() {// 线程执行的代码} }// 创建并启动线程 MyThread…

ThreadPoolExecutor线程池submit() 和 excute()区别

在研究ThreadPoolExecutor线程池的时候，发现可以有两种启动线程的方法：submit(Runnable runnable)，excute(Runnable runnable) 先说个结论吧： submit()方法，可以提供Future < T > 类型的返回值。 executor()方…

Java ~ Executor ~ ScheduledExecutorService【源码】

前言相关系列《Java ~ Executor【目录】》（持续更新）《Java ~ Executor ~ ScheduledExecutorService【源码】》（学习过程/多有漏误/仅作参考/不再更新）《Java ~ Executor ~ ScheduledExecutorService【总结】》（学习…

Java并发编程：ThreadPoolExecutor常用线程池

目录线程池的分类常用线程池(ThreadPoolExecutor)示例 CachedThreadPool FixedThreadPool SingleThreadExecutor ThreadPoolExecutor类分析三种线程池(返回ThreadPoolExecutor)构造方法 ThreadPoolExecutor中的成员变量三种线程池(返回ThreadPoolExecutor类)分析 …

为什么我的集群一个 Spark Executor / Yarn Container 只分配一个vCore?

在很多集群里，在关闭了Spark的DynamicAllocation的前提下（避免自动申请空闲资源，干扰测试结果），都会观察到：提交Spark作业时，申请 1 个 driver + n 个 executor 会在Yarn上对应创建 n+1 个 container，但是每个container只有一个vCore，通过--driver-cores和--executor-…

Executor - 一文搞懂 ThreadPoolExecutor 与 BlockingQueue

一.引言 ThreadPool 是 java 的一种多线程处理方式，和前面提到了 RedisPool 类似，即通过一个 pool 批量管理，ThreadPool 管理线程，RedisPool 管理 Jedis 连接。下面主要介绍 ThreadPool 的参数含义，BlockingQueue 的几…

Java ~ Executor ~ FutureTask【源码】

前言文章相关系列：《Java ~ Executor【目录】》（持续更新）相关系列：《Java ~ Executor ~ FutureTask【源码】》（学习过程/多有漏误/仅作参考/不再更新）相关系列：《Java ~ Executor ~ FutureT…

Java线程池ThreadPoolExecutor应用(Spring Boot微服务)

记录：475 场景：在Spring Boot微服务中使用Java线程池ThreadPoolExecutor。实现Runnable接口提交线程任务到线程池。版本：JDK 1.8,Spring Boot 2.6.3。 1.使用注解配置线程池ThreadPoolExecutor (1)说明 ThreadPoolExecutor，…

多任务处理：管理调度Executor 接口

系统管理调度：Executor接口在上一节中我们已经看到，将客户服务器协议的细节封装起来（如EchoProtocol.java），就可以通过同一个协议实现来使用不同的"调度"方法（如，TCPEchoServerThrea…

多任务处理：管理调度Executor 接口

系统管理调度：Executor接口在上一节中我们已经看到，将客户服务器协议的细节封装起来（如EchoProtocol.java），就可以通过同一个协议实现来使用不同的"调度"方法（如，TCPEchoServerThrea…

Java线程Executor框架详解与使用

在HotSpot VM的线程模型中，Java线程被一对一映射为本地操作系统线程。Java线程启动时会创建一个本地操作系统线程；当该Java线程终止时，这个操作系统线程也会被回收，在JVM中我们可以通过-Xss设置每个线程的大小。操作系统会调度所有…

Java ~ Collection/Executor ~ TransferQueue【总结】

一概括简介 TransferQueue（迁移队列）接口（下文简称迁移队列）是BlockingQueue（阻塞队列）接口的两大子接口之一，在原本的操作定义上新增了迁移操作的定义。所谓的迁移是一种作用于操作本身&…

Doug Lea的Executor线程池

Executor框架是指java5中引入的一系列并发库中与executor相关的一些功能类，其中包括线程池，Executor，Executors，ExecutorService，CompletionService，Future，Callable等。他们的关系为&#xff1…

【java笔记】java中的线程池ThreadPoolExecutor的原理和使用

本文摘自简书作者“juconcurrent”的文章java线程池的使用。线程池顾名思义就是存放线程的池子，本质是一种对象池，用来管理线程资源。线程池的使用避免了每次使用线程时重复的创建线程，而是从线程池中取出一个线程来执行任务，执行…

Executor - Shutdown、ShutdownNow、awaitTermination 详解与实战

一.引言使用 executor 线程池时经常用到 shutdown / shutdownNow awaitTermination 方法关闭线程池，下面看下几种方法的定义与常见用法。二.API 释义 1.shutdown /*** Initiates an orderly shutdown in which previously submitted* tasks are executed, but …

Java ~ Executor【总结】

一概述简介 Executor（执行器）接口（下文简称执行器接口）是Executor（执行器）框架最顶级的接口，定义了执行器的概念，并明确了该框架的核心目标：将任务的递交与执行分离&am…