当前位置: 首页 > news >正文

hashedWheelTimer类

hashedWheelTimer类

  • 目录
    • 概述
      • 需求:
    • 设计思路
    • 实现思路分析
      • 1.hashedWheelTimer类
    • 拓展实现
  • 参考资料和推荐阅读

Survive by day and develop by night.
talk for import biz , show your perfect code,full busy,skip hardness,make a better result,wait for change,challenge Survive.
happy for hardess to solve denpendies.

目录

在这里插入图片描述

概述

hashedWheelTimer类

需求:

设计思路

实现思路分析

1.hashedWheelTimer类

这个类用来计划执行非精准的I/O超时。可以通过指定每一格的时间间隔来改变执行时间的精确度。在大多数网络应用中,I/O超时不需要十分准确,因此,默认的时间间隔是100 毫秒,这个值适用于大多数场合。HashedWheelTimer内部结构可以看做是个车轮,简单来说,就是TimerTask的hashTable的车轮。车轮的size默认是512,可以通过构造函数自己设置这个值。注意,当HashedWheelTimer被实例化启动后,会创建一个新的线程,因此,你的项目里应该只创建它的唯一一个实例。

通过上面demo,我再说明一下hashedWheelTimer类的构造。
超时任务1000毫秒,超时之后,由hashedWheelTimer类中的worker线程,执行超时之后的任务(打印名字)。hashedWheelTimer有32个槽(相当于一个圆的32分之一),每移动一个槽的时间是100毫秒。
任务需要经过的tick数为: 1000 / 100 = 10次 (等待时长 / tickDuration)
任务需要经过的轮数为 : 10次 / 32次/轮 = 0轮 (tick总次数 / ticksPerWheel)
因为任务超时后不能马上被worker线程执行,需要等到worker线程移到相应卡槽位置时才会执行,因此说执行时间不精确。

hashedWheelTimer的核心是Worker线程,主要负责每过tickDuration时间就累加一次tick. 同时, 也负责执行到期的timeout任务, 此外,还负责添加timeou任务到指定的wheel中。

拓展实现

这里参考:github:简单实现上述流程:
入门级实现:
: 部分源码实现.
: 源码实现

我们可以看到,这里使用的优先级队列是一个 MPSC(Multiple Producer Single Consumer)的队列,刚好适用于这里的多生产线程,单消费线程的场景。而在 Dubbo 中,使用的队列是 LinkedBlockingQueue,它是一个以链表方式组织的线程安全的队列。

另外就是注意这里调用的 start() 方法,如果该任务是第一个提交的任务,它会负责工作线程的启动。

工作线程开始工作
1、第一个代码片段中的 while 换成 if 行不行?

不行。

Object 中的 wait/notify 存在操作系统的假唤醒,所以一般都在 while 循环里,但是这里的 CountDownLatch 不会,所以看上去这里的 while 是没必要的。但是 CountDownLatch 没有提供 awaitUninterruptibly() 方法,所以这里其实在处理线程中断的情况。

参考资料和推荐阅读

  1. https://blog.csdn.net/daobuxinzi/article/details/122709545

欢迎阅读,各位老铁,如果对你有帮助,点个赞加个关注呗!同时,期望各位大佬的批评指正~

http://www.lryc.cn/news/104478.html

相关文章:

  • 【自动化测试】Selenium IDE脚本编辑与操作
  • 杭电多校2023“钉耙编程”中国大学生算法设计超级联赛(5)
  • Matlab进阶绘图第24期—悬浮柱状图
  • 【题解】链表中倒数最后k个结点、删除链表的倒数第n个节点
  • 网络安全大厂面试题
  • 7.事件类型
  • ts中声明引入未使用的报错——解决方案
  • 集团MySQL的酒店管理系统
  • Kotlin基础(九):对象和委托
  • 八大排序算法--希尔排序(动图理解)
  • 数据结构之常见排序算法
  • Java版企业电子招标采购系统源代码Spring Boot + 二次开发 + 前后端分离 构建企业电子招采平台之立项流程图
  • 2.2 模型与材质基础
  • 什么是Docker
  • 1109. 航班预订统计
  • [SQL挖掘机] - 窗口函数 - 合计: rollup
  • 2022年全国硕士研究生入学统一考试管理类专业学位联考写作试题——解析版
  • 元类在测试框架中的运用
  • VBA快速交叉分段标记字符颜色
  • 根据Pytorch源码实现的 ResNet18
  • 药品管理系统servlet+jsp+sql医院药店仓库进销存java源代码mysql
  • 这9个UI设计工具一定码住!非常好用
  • gin通过反射来执行动态的方法
  • java高并发系列 - 第23天:JUC中原子类,一篇就够了
  • 《HeadFirst设计模式(第二版)》第一章源码
  • insert into select用法
  • 图像识别技术:计算机视觉的进化与应用展望
  • 【免费送书】重新定义Python学习!
  • Qt 4. 发布exe
  • 消息队列的使用场景以及优缺点