60 results for “topic:blocking-queue”
📌 异步线程池框架,支持线程池动态变更&监控&报警,无需修改代码轻松引入。Asynchronous thread pool framework, support Thread Pool Dynamic Change & monitoring & Alarm, no need to modify the code easily introduced.
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
Practical multithreading tutorials. Languages supported: C++, Java, C#, Python, Javascript/Nodejs.
Queues on cue: low-latency persistent blocking queues, processors, and graphs via Chronicle Queue
System design exercises by Arpit Bhayani
Simple, performant, goroutine safe queues, useful as resource pools or job queues.
a Java FIFO blocking queue with "close" semantics. designed for virtual threads.
Thread safe, blocking, generic dequeue data structure for Go
Simple HTTP server written in Java
The Divine Synchronization Library
Persistent java.util.Queue implementation with Xodus
Code repository for all the articles on design patterns at codepumpkin.com
A FIFO blocking queue implemented in C.
Quoridor game implementation integrated with a versatile and reusable AI agent for solving two-player board games
In this practical I wrote an array-based implementation of a dynamically-chosen fixed-size generic Queue in C, and a thread-safe, blocking queue.
Implementation of a BlockingQueue in Java
[自用轮子] 一个多线程/多进程工具模块(生产者-消费者模式实现)
Blocking ring buffer in C++11
Performs a concurrent mapping with back pressure (won't iterate all source items if the consumer is not reading).
Simple thread pool manager implemented in Java
This project implements a Kafka-inspired message processing system in pure Java. It focuses on backpressure, bounded concurrency, disk persistence, and graceful shutdown.
OffHeap lists and queues, using Unsafe class, DirectByteBuffer, and Memory Mapped Files
A demo project for an assets matching engine.
C++11 std::vector-based blocking queue with high throughput.
Blocking Queue in Java
Parallel process pool that throttles the task producer thread to avoid out-of-memory issues
utils for cpp
No description provided.
Project to implement WorkerClass which execute task asynchronously
Producer Consumer Problem