DefaultMessageStore-CommitLog-MapedFileQueue.allocateMapedFileService初始化链

刚刚在研究rocketmq生成文件的源码。零时记录一下MapedFileQueue中属性AllocateMapedFileService allocateMapedFileService的初始化链。

首先这个服务实在DefaultMessageStore中初始化完成并启动的，然后DefaultMessageStore把AllocateMapedFileService对象传给了CommitLog（绿色箭头）

然后CommitLog初始化MapedFileQueue的时候又穿给了它。

最终MapedFileQueue有了两种创建文件的方式，一种就是这个服务线程：AllocateMapedFileService

使用起来也很方便：

只要调用它的这个方法就可以了：

allocateMapedFileService.putRequestAndReturnMapedFile(nextFilePath,
                                nextNextFilePath, this.mapedFileSize);

这个方法会把这三个参数分装，然后放入它的优先级队列中PriorityBlockingQueue，这个服务线程就会不断的从这个优先级队列中拿需要创建文件的参数来创建文件来。

时间： 2024-10-10 12:01:06

DefaultMessageStore-CommitLog-MapedFileQueue.allocateMapedFileService初始化链的相关文章

DS之顺序栈和链队实现回文判断

顺序栈和链队的基本操作就不再一一列举了,要想实现回文判断,先来了解什么是回文?"回文"一字符串正着读和反着读是相同的字符序列,如"abcba","abba"为"回文","abab"则不是"回文". 其次就是顺序栈和链队如何实现回文的判断?将输入的字符串依次入栈和入队,然后再依次出栈和出队,由于入栈和入队是相同的序列,然而出栈和出队是相反的序列,这就实现了回文的判断. 最后考虑要用到顺序栈

描述: 链栈,即栈的链式存储结构,链栈通常使用不带头结点的单链表来表示,因此其结点的结构和单链表的结点结构相同. 在一个链栈中,栈底就是链表的最后一个结点,而栈顶总是链表的第一个结点.因此,新入栈的元素即为链表中采用头插法新加入的结点,一个链栈可以由栈顶指针唯一确定,当top为NULL时,则表示该栈是一个空的链栈. 实现: 链栈结点的类型描述: typedef int ElemType; typedef struct node{ ElemType data; struct nod

小猪的数据结构辅助教程——3.2 栈与队列中的链栈

小猪的数据结构辅助教程--3.2 栈与队列中的链栈标签(空格分隔): 数据结构 1.本节引言: 嗯,本节没有学习路线图哈,因为栈我们一般都用的是顺序栈,链栈还是顺带提一提吧, 栈因为只是栈顶来做插入和删除操作,所以较好的方法是将栈顶放在单链表的头部,栈顶指针与单链表的头指针合二为一~所以本节只是讲下链栈的存储结构和基本操作! 2.链栈的存储结构与示意图存储结构: typedef struct StackNode { SElemType data; //存放的数据 struct StackN

_DataStructure_C_Impl:只有队尾指针的链式循环队列

//_DataStructure_C_Impl: #include<stdio.h> #include<stdlib.h> #include<string.h> typedef char DataType; typedef struct snode{ //链式堆栈结点类型定义 DataType data; struct snode *next; }LSNode; typedef struct QNode{ //只有队尾指针的链式循环队列类型定义 DataType dat

Java数据结构-线性表之栈（顺序栈和链栈）

栈的定义:(特殊的线性表) ??仅在表的一端进行插入和删除的线性表.允许插入.删除的这一端称为栈顶,另一端称为栈底.表中没有元素时称为空栈. ??被称为后进先出的线性表(Last In First Out),简称 LIFO表,或被称为先进后出的线性表(First In Last Out),简称 FILO表. ??栈更具存储方式的不同分为两种:顺序栈和链栈. 顺序栈: 和顺序表一样,顺序栈也采用数组来存放数据元素: 为了保证栈底位置的不变,采用数组下标为0的位置作为顺序栈的栈底. 而栈顶指针的最大

数据结构之自建算法库——链队（链式队列）

本文针对数据结构基础系列网络课程(3):栈和队列中第10课时队列的链式存储结构及其基本运算的实现. 按照"0207将算法变程序"[视频]部分建议的方法,建设自己的专业基础设施算法库. 链队算法库采用程序的多文件组织形式,包括两个文件: 1.头文件:liqueue.h,包含定义链队数据结构的代码.宏定义.要实现算法的函数的声明: #ifndef LIQUEUE_H_INCLUDED #define LIQUEUE_H_INCLUDED typedef char ElemType; typ

数据结构之自建算法库——链栈

本文针对数据结构基础系列网络课程(3):栈和队列中第4课时栈的链式存储结构及其基本运算实现. 按照"0207将算法变程序"[视频]部分建议的方法,建设自己的专业基础设施算法库. 链栈算法库采用程序的多文件组织形式,包括两个文件: 1.头文件:listack.h,包含定义链栈数据结构的代码.宏定义.要实现算法的函数的声明: #ifndef LISTACK_H_INCLUDED #define LISTACK_H_INCLUDED typedef char ElemType; typede

C++链栈基本操作

1 #include <iostream> 2 using namespace std; 3 4 struct Node 5 { 6 int data; 7 Node *next; 8 }; 9 10 /*初始化链栈*/ 11 void InitChainStack(Node *top) 12 { 13 top->next=0; 14 } 15 16 /*往栈里压进数据elem*/ 17 int Push(Node *top, int elem) 18 { 19 Node *p=(Nod

链栈的基本接口实现

#include <conio.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #define TRUE 1 #define FALSE 0 #define OK 1 #define ERROR 0 #define IBFEASIBLE -1 #define OVERFLOW -2 typedef int Status; typedef int ElemType; /* 元素类型为i