Dubbo3之SerializingExecutor

前言

Dubbo3 提供了一个挺有意思的 Executor,用来将提交到线程池里的任务按顺序串行执行。

需求背景:你有一个线程池,但是你不想修改它,现在你的需求是要把提交上去的任务按顺序串行执行。
在这样一个需求背景下,SerializingExecutor 诞生了。

SerializingExecutor 在 Dubbo3 的应用场景是:针对 HTTP2 上的 Stream 接收到的 Frame 要按顺序处理。

SerializingExecutor

SerializingExecutor 类图很简单,首先它实现了 Executor 接口,意味着它可以执行提交的任务。当然了,它本身不创建线程,会依赖实际的 Executor 执行任务。
它还实现了 Runnable 接口,意味着它也是一个可执行的任务,可以被提交到 Executor 里执行。
在这里插入图片描述

SerializingExecutor 按顺序串行执行任务的逻辑很简单,核心是:提交的任务先入队等待,而后再按顺序串行化的调度任务执行。

public final class SerializingExecutor implements Executor, Runnable {// 运行状态 CAS防止并发private final AtomicBoolean atomicBoolean = new AtomicBoolean();// 实际跑任务的线程池private final Executor executor;// 任务队列private final Queue<Runnable> runQueue = new ConcurrentLinkedQueue<>();
}

SerializingExecutor 本身不创建线程,不具备异步执行任务的能力,它依赖一个实际干活的 Executor。

public SerializingExecutor(Executor executor) {this.executor = executor;
}

它重写了execute()方法,避免任务被直接执行,而是先入队等待,再自己去调度执行。

@Override
public void execute(Runnable r) {// 先入队runQueue.add(r);// 调度执行schedule(r);
}

schedule()调度任务执行,通过CAS防止并发。它把自己提交到 executor 里去执行了,所以我们重点看run()

private void schedule(Runnable removable) {if (atomicBoolean.compareAndSet(false, true)) {boolean success = false;try {executor.execute(this);success = true;} finally {if (!success) {if (removable != null) {runQueue.remove(removable);}atomicBoolean.set(false);}}}
}

run()也很简单,就是循环从队列里取出任务,然后挨个执行,队列本身保证了任务的先进先出,所以任务是按顺序串行执行的。

@Override
public void run() {Runnable r;try {// 循环出队 先进先出 按顺序执行while ((r = runQueue.poll()) != null) {InternalThreadLocalMap internalThreadLocalMap = InternalThreadLocalMap.getAndRemove();try {r.run();} catch (RuntimeException e) {LOGGER.error(COMMON_ERROR_RUN_THREAD_TASK, "", "", "Exception while executing runnable " + r, e);} finally {InternalThreadLocalMap.set(internalThreadLocalMap);}}} finally {atomicBoolean.set(false);}if (!runQueue.isEmpty()) {schedule(null);}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/103487.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

CSS scoped 属性的原理

scoped 一、scoped 是什么&#xff1f;二、实现原理 一、scoped 是什么&#xff1f; 在 Vue 组件中&#xff0c;为了使样式私有化&#xff08;模块化&#xff09;&#xff0c;不对全局造成污染&#xff0c;可以在 style 标签上添加 scoped 属性以表示它的只属于当下的模块&am…

计算机提示mfc120u.dll缺失(找不到)怎么解决

在计算机领域&#xff0c;mfc120u.dll是一个重要的动态链接库文件。它包含了Microsoft Foundation Class (MFC) 库的特定版本&#xff0c;用于支持Windows操作系统中的应用程序开发。修复mfc120u.dll可能涉及到解决与该库相关的问题或错误。这可能包括程序崩溃、运行时错误或其…

基于swing的图书借阅系统java jsp书店进销存mysql源代码

本项目为前几天收费帮学妹做的一个项目&#xff0c;Java EE JSP项目&#xff0c;在工作环境中基本使用不到&#xff0c;但是很多学校把这个当作编程入门的项目来做&#xff0c;故分享出本项目供初学者参考。 一、项目描述 基于swing的图书借阅系统 系统有2权限&#xff1a;管…

手搭手入门MyBatis-Plus

MyBatis-Plus Mybatis-Plus介绍 为简化开发而生 MyBatis-Plus(opens new window)&#xff08;简称 MP&#xff09;是一个 MyBatis(opens new window) 的增强工具&#xff0c;在 MyBatis 的基础上只做增强不做改变&#xff0c;为简化开发、提高效率而生。 特性 无侵入&#…

【洛谷算法题】P1000-超级玛丽游戏【入门1顺序结构】

&#x1f468;‍&#x1f4bb;博客主页&#xff1a;花无缺 欢迎 点赞&#x1f44d; 收藏⭐ 留言&#x1f4dd; 加关注✅! 本文由 花无缺 原创 收录于专栏 【洛谷算法题】 文章目录 【洛谷算法题】P1000-超级玛丽游戏【入门1顺序结构】&#x1f30f;题目描述&#x1f30f;输入格…

【无标题】idea 中 SpringBoot 点击运行没反应,按钮成灰色

问题描述 在使用 Spring Boot 开发项目时&#xff0c;可能会遇到一个问题&#xff1a;点击运行按钮后&#xff0c;控制台没有任何输出&#xff0c;项目界面也没有显示。这种情况可能是由多种原因导致的&#xff0c;本文将介绍一些常见的解决方法。 解决方法 首先看下Groovy插…

如何限制PDF打印?限制清晰度?

想要限制PDF文件的打印功能&#xff0c;想要限制PDF文件打印清晰度&#xff0c;都可以通过设置限制编辑来达到目的。 打开PDF编辑器&#xff0c;找到设置限制编辑的界面&#xff0c;切换到加密状态&#xff0c;然后我们就看到 有印刷许可。勾选【权限密码】输入一个PDF密码&am…

UI设计第一步,在MasterGo上开展一个新项目

我们都知道&#xff0c;一个完整的项目&#xff0c;要经历创建团队、搭建组件库、应用规范以及管理设计资产&#xff0c;那么今天小编就在MasterGo中带你从0到1开展一个全新的项目。 你一定遇到过这种情况&#xff0c;同团队的设计师&#xff0c;由于使用不同版本或不同软件&a…

js将搜索的关键字加颜色

js将搜索的关键字加颜色 使用正则匹配关键字并加入span标签&#xff0c;页面渲染时使用v-html渲染即可 // 文本框内容 let searchCont 测试;const reg new RegExp((${searchCont.value}), g); let data 图片保存测试A; data data.replace(reg, <span style"color:…

docker第二次作业

1、使用mysql:5.6和 owncloud 镜像&#xff0c;构建一个个人网盘。 拉取镜像 docker pull mysql:5.6 docker pull ow ncloud 运行镜像生成容器 [rootharbor ~]# docker run -d --name mydb1 --env MYSQL_ROOT_PASSWORD123456 mysql:5.6 [rootharbor ~]# docker run -d --name…

Spring Boot整合RabbitMQ之发布与订阅模式

RabbitMQ的模式中&#xff0c;常用的模式有&#xff1a;简单模式&#xff0c;发布与订阅模式&#xff0c;工作模式&#xff0c;路由模式&#xff0c;主题模式。简单模式不太会运用到工作中&#xff0c;我们可以使用 RabbitMQ 的发布订阅模式&#xff0c;实现&#xff1a; 用户…

文件/文件夹加密:Newsoftwares Folder Lock 7.9.0 Crack

Newsoftwares Folder Lock 7.9文件夹锁 版本7 防弹数据加密 - 在几秒钟内锁定文件夹 - 即时加密文件 - 密码保护 USB/外部驱动器 - 粉碎并永久删除文件等等...... 视窗 向量 受到数百万人的信赖 82,283,016次下载并且还在增加中... 什么为什么如何 奖项常问问题特征丢失登记感…

五、修改官方FreeRTOS例程(STM32F1)

1、官方源码下载 (1)进入FreeRTOS官网&#xff1a;FreeRTOS官网 (2)下载FreeRTOS。(选择带示例的下载) 2、删减目录 (1)下载后解压的FreeRTOS文件如下图所示。 (2)删除下图中红框勾选的文件。 FreeRTOS-Plus&#xff0c;FreeRTOS的生态文件&#xff0c;非必需的。tools&…

油烟监管云平台在油烟净化技术中的应用研究

安科瑞 华楠 摘 要&#xff1a;介绍了生活中餐饮业油烟废气的排放特点、产生过程及其对人体和环境带来的环境&#xff0c;分析了餐饮油烟组成成分的成分特性及相关的致病症状。油烟净化器仍然是目前治理餐饮油烟比较有用的方法&#xff0c;基于高压静电原理的复合型油烟净化技…

长时间带什么耳机最舒服,分享长时间佩戴舒服的耳机推荐

时代在进步&#xff0c;科技在不断革新。近年来&#xff0c;一种崭新的耳机——骨传导耳机&#xff0c;如火如荼地进驻耳机市场&#xff0c;引起一阵热潮。不论是平日里的工作出勤还是运动时的挥洒汗水&#xff0c;相比传统耳机&#xff0c;骨传导耳机无疑更加贴合现代生活的需…

SqlServer2019—解决SQL Server 无法连接127.0.0.1的问题

1、打开SQL Server 2019配置管理器 2、SQL Servere 网络配置(启用 Named Pipes 和 TCP/IP) 3、修改TCP/IP协议(右键选择属性—IP地址)&#xff0c;具体如下图所示&#xff1a; 4、重启SQL Server服务

重排链表(C语言)

题目&#xff1a; 示例&#xff1a; 思路&#xff1a; 这题我们将使用栈解决这个问题&#xff0c;利用栈先进后出的特点&#xff0c;从链表的中间位置进行入栈&#xff0c;寻找链表的中间位置参考&#xff1a;删除链表的中间节点&#xff0c;之后从头开始进行连接。 本题使用…

JVM——StringTable面试案例+垃圾回收+性能调优+直接内存

JVM——引言JVM内存结构_北岭山脚鼠鼠的博客-CSDN博客 书接上回内存结构——方法区。 这里常量池是运行时常量池。 方法区 面试题 intern()方法 intern() 方法用于在运行时将字符串添加到内部的字符串池stringtable中&#xff0c;并返回字符串池stringtable中的引用。 返…

vue 使用C-Lodop打印小票

先从官网下载js文件 https://www.lodop.net/LodopDemo.html 打开安装程序&#xff0c;一直下一步既可&#xff0c;我这边已经安装过就不演示了。 // 引入 import { getLodop } from /utils/CLodopfuncs.js;// 使用 let LODOP getLodop()let Count LODOP.GET_PRINTER_COUNT…

13. Docker实战之安装MySQL

目录 1、前言 2、部署MySQL 2.1、Docker仓库查看镜像 2.2、拉取MySQL镜像 2.3、创建持久化目录 2.4、启动MySQL容器 2.5、查看宿主机上的MySQL目录 2.6、本地MySQL测试 2.7、新建MySQL用户&#xff0c;配置远程访问 2.8、本地Navicat连接测试 3、为什么数据库不适合D…