皮皮网

1.RabbitMQ源码解析c++4----Routing
2.Java并发编程笔记之LinkedBlockingQueue源码探究
3.JDK源码分析-Queue, Deque
4.求用vbnet 实现先进先出即队列得源代码
5.一篇讲解CPU性能指标提取及源码分析

RabbitMQ源码解析c++4----Routing

       在构建日志记录系统教程中，我们学习了如何将日志消息广播给多个接收器，但并未提供根据消息严重性筛选的功能。本教程将对系统进行扩展，允许仅订阅特定严重性消息，如直接将关键错误消息定向至日志文件，源码的加减运算同时保留控制台中的所有日志输出。

       直接交换机（Direct Exchange）引入了灵活性，它根据消息的路由键与队列的绑定键完全匹配的原则进行消息路由。此实现中，我们使用直接交换机取代之前的扇出交换机。这样，发布到直接交换机的消息将根据其路由键被路由至与该键匹配的队列。

       直接交换 X 在这里与两个队列绑定，其绑定键分别为橙色、黑色和绿色。橙色键的消息将被路由至队列 Q1，黑色或绿色键的消息将传递至队列 Q2。非匹配消息将被丢弃。

       允许多个队列通过相同的绑定键进行绑定是合法的。以此为例，我们可以在 X 与 Q1 间添加一个绑定键为黑色的翎风源码绑定，此时直接交换机的行为类似于扇出，将消息广播至所有匹配队列。黑色键的消息将同时传至 Q1 和 Q2。

       在日志记录系统中，我们将消息发送至直接交换机而非扇出交换机，利用日志严重性作为路由键。这样，接收脚本能够选择接收特定严重性的日志。首先，我们关注日志的发布。

       为了实现这一模型，代码示例展示了在 RabbitMQ 队列系统中声明直接类型的交换器并发布消息。逐行解释如下：

       在代码中，使用了 amqp_exchange_declare() 函数来声明一个交换机。该函数通过向 AMQP 服务器发送交换机声明请求来创建新的交换机或获取现有交换机的信息。函数的参数包括交换机名称、类型、持久化设置、自动删除等，根据需求创建适合的消息路由和分发。

       amqp_cstring_bytes("direct") 函数用于将 C 风格字符串转换为 AMQP 字节序列，网站 acess 源码表示直连交换机的名称。此操作在 AMQP 库函数调用中使用。

       amqp_queue_declare() 函数声明了一个消息队列，并将返回结果存储在 amqp_queue_declare_ok_t 类型的指针中。此操作用于创建新队列或获取现有队列的信息，并为后续操作提供队列属性和状态。

       amqp_basic_consume() 函数启动消费者并订阅消息队列中的消息。此操作允许开始接收指定队列中的消息，并将结果以消费者标识存储。

       amqp_consume_message() 函数用于接收订阅的消息，将消息存储在 amqp_message_t 类型的结构体中。此函数为阻塞调用，持续等待直至接收到消息，提供接收消息的包装信息。

Java并发编程笔记之LinkedBlockingQueue源码探究

       LinkedBlockingQueue 是基于单向链表实现的一种阻塞队列，其内部包含两个节点用于存放队列的首尾，并维护了一个表示元素个数的原子变量 count。同时，它利用了两个 ReentrantLock 实例（takeLock 和 putLock）来保证元素的原子性入队与出队操作。此外，notEmpty 和 notFull 两个信号量与条件队列用于实现阻塞操作，本机测试源码使得生产者和消费者模型得以实现。

       LinkedBlockingQueue 的实现主要依赖于其内部锁机制和信号量管理。构造函数默认容量为最大整数值，用户可自定义容量大小。offer 方法用于尝试将元素添加至队列尾部，若队列未满则成功，返回 true，反之返回 false。若元素为 null，则抛出 NullPointerException。put 方法尝试将元素添加至队列尾部，并阻塞当前线程直至队列有空位，若被中断则抛出 InterruptedException。通过使用 putLock 锁，确保了元素的原子性添加以及元素计数的原子性更新。

       在实现细节上，offer 方法通过在获取 putLock 的同时检查队列是否已满，避免了不必要的元素添加。若队列未满，则执行入队操作并更新计数器，同时考虑唤醒等待队列未满的快手播放源码线程。此过程中，通过 notFull 信号量与条件队列协调线程间等待与唤醒。

       put 方法则在获取 putLock 后立即检查队列是否满，若满则阻塞当前线程至 notFull 信号量被唤醒。在入队后，更新计数器，并考虑唤醒等待队列未满的线程，同样通过 notFull 信号量实现。

       poll 方法用于从队列头部获取并移除元素，若队列为空则返回 null。此方法通过获取 takeLock 锁，保证了在检查队列是否为空和执行出队操作之间的原子性。在出队后，计数器递减，并考虑激活因调用 poll 或 take 方法而被阻塞的线程。

       peek 方法类似，但不移除队列头部元素，返回 null 若队列为空。此方法也通过获取 takeLock 锁来保证操作的原子性。

       take 方法用于阻塞获取队列头部元素并移除，若队列为空则阻塞当前线程直至队列不为空。此方法与 put 方法类似，通过 notEmpty 信号量与条件队列协调线程间的等待与唤醒。

       remove 方法用于移除并返回指定元素，若存在则返回 true，否则返回 false。此方法通过双重加锁机制（fullyLock 和 fullyUnlock）来确保元素移除操作的原子性。

       size 方法用于返回当前队列中的元素数量，通过 count.get() 直接获取，确保了操作的准确性。

       综上所述，LinkedBlockingQueue 通过其独特的锁机制和信号量管理，实现了高效、线程安全的阻塞队列操作，适用于生产者-消费者模型等场景。

JDK源码分析-Queue, Deque

       Queue 和 Deque 是 Java 中的两个接口，分别代表队列和双端队列。

       Queue 接口提供了基本的队列操作：入队（enqueue）和出队（dequeue）。同时，Queue 接口有 6 个方法，分为入队、出队和遍历三类。与之不同的是，当队列为空时，element() 方法会抛出异常，而 peek() 方法则会返回 null。

       Deque 接口继承自 Queue 接口，表示双端队列，具备「队列」和「栈」的特性。双端队列可以分别从两端插入和移除元素，而一般队列只能从尾部插入元素、头部移除元素。Deque 接口定义了入队、出队、遍历以及独有的一些操作方法。Deque 作为双端队列，不仅继承了 Queue 的方法，还提供了额外的双端操作。

       综上，Queue 提供了基本的队列功能，而 Deque 在 Queue 的基础上增加了双端操作，使其兼具队列和栈的特性。在实际应用中，根据需求选择合适的接口可以提高代码的灵活性和效率。

求用vbnet 实现先进先出即队列得源代码

       VB.Net中的队列类在System.Collections.Generic命名空间中，名字叫Queue，是一个泛型类。

       实例化该类：

       Dim myQueue As Queue<Int>

       myQueue = new Queue<Int>();

       然后可以通过Queue中的Enqueue和Dequeue函数进行入队出队操作：

       With myQueue

        .Enqueue(1)

        .Enqueue(2)

        .Enqueue(3)

        .Enqueue(4)

        .Enqueue(5)

       End With

       For i = 0 To 5 Step 1

        Console.WriteLine(myQueue.Dequeue())

       Next i

       显示结果：

       1

       2

       3

       4

       5

一篇讲解CPU性能指标提取及源码分析

       这篇报告主要根据CPU性能指标——运行队列长度、调度延迟和平均负载，对系统的性能影响进行简单分析。

       CPU调度程序运行队列中存放的是那些已经准备好运行、正等待可用CPU的轻量级进程。如果准备运行的轻量级进程数超过系统所能处理的上限，运行队列就会很长，运行队列长表明系统负载可能已经饱和。

       代码源于参考资料1中map.c用于获取运行队列长度的部分代码。

       在系统压力测试前后，使用压力测试工具stress-ng，可以看到运行队列长度的明显变化，从3左右变化到了左右。

       压力测试工具stress-ng可以用来进行压力测试，观察系统在压力下的表现，例如运行队列长度、调度延迟、平均负载等性能指标。

       在系统运行队列长度超过虚拟处理器个数的1倍时，需要关注系统性能。当运行队列长度达到虚拟处理器个数的3~4倍或更高时，系统的响应就会非常迟缓。

       解决CPU调用程序运行队列过长的方法主要有两个方面：优化调度算法和增加系统资源。

       所谓调度延迟，是指一个任务具备运行的条件（进入 CPU 的 runqueue），到真正执行（获得 CPU 的执行权）的这段时间。通常使用runqlat工具进行测量。

       在正常情况下使用runqlat工具，可以查看调度延迟分布情况。压力测试后，调度延迟从最大延迟微秒变化到了微秒，可以明显的看到调度延迟的变化。

       平均负载是对CPU负载的评估，其值越高，说明其任务队列越长，处于等待执行的任务越多。在系统压力测试前后，通过查看top命令可以看到1分钟、5分钟、分钟的load average分别从0.、1.、1.变化到了4.、3.、1.。

       总结：当系统运行队列长度、调度延迟和平均负载达到一定值时，需要关注系统性能并进行优化。运行队列长度、调度延迟和平均负载是衡量系统性能的重要指标，通过监控和分析这些指标，可以及时发现和解决问题，提高系统的稳定性和响应速度。