Topic: "blocking-queue"
opengoofy/hippo4j
📌 异步线程池框架,支持线程池动态变更&监控&报警,无需修改代码轻松引入。Asynchronous thread pool framework, support Thread Pool Dynamic Change & monitoring & Alarm, no need to modify the code easily introduced.
Language: Java - Size: 22.6 MB - Last synced at: 5 days ago - Pushed at: 3 months ago - Stars: 5,773 - Forks: 1,215

adrianbrad/queue
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
Language: Go - Size: 106 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 289 - Forks: 15

thanhit95/multi-threading
Practical multithreading tutorials. Languages supported: C++, Java, C#, Python, Javascript/Nodejs.
Language: C++ - Size: 840 KB - Last synced at: 12 days ago - Pushed at: about 1 year ago - Stars: 167 - Forks: 48

zalky/cues
Queues on cue: low-latency persistent blocking queues, processors, and graphs via Chronicle Queue
Language: Clojure - Size: 233 KB - Last synced at: about 1 month ago - Pushed at: about 2 years ago - Stars: 105 - Forks: 2

theodesp/blockingQueues
Simple, performant, goroutine safe queues, useful as resource pools or job queues.
Language: Go - Size: 65.4 KB - Last synced at: 27 days ago - Pushed at: over 7 years ago - Stars: 24 - Forks: 3

Tomiwa-Ot/java-web-server
Simple HTTP server written in Java
Language: Java - Size: 2.2 MB - Last synced at: 3 days ago - Pushed at: about 2 years ago - Stars: 7 - Forks: 1

AmrSaber/go-blocking-dequeue
Thread safe, blocking, generic dequeue data structure for Go
Language: Go - Size: 55.7 KB - Last synced at: 6 months ago - Pushed at: almost 3 years ago - Stars: 7 - Forks: 1

ralscha/xodus-queue
Persistent java.util.Queue implementation with Xodus
Language: Java - Size: 304 KB - Last synced at: 25 days ago - Pushed at: 2 months ago - Stars: 6 - Forks: 1

Divine-Software/divine-synchronization
The Divine Synchronization Library
Language: TypeScript - Size: 151 KB - Last synced at: 12 days ago - Pushed at: 6 months ago - Stars: 5 - Forks: 0

gmarma23/QuoridorEngine
Quoridor game implementation packed with a generalized and fully reusable 2-player board game solver AI agent
Language: C# - Size: 482 KB - Last synced at: over 1 year ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 0

robaho/closablequeue
a Java FIFO blocking queue with "close" semantics. designed for virtual threads.
Language: Java - Size: 104 KB - Last synced at: 14 days ago - Pushed at: 4 months ago - Stars: 3 - Forks: 1

Tishacy/QSpider
[自用轮子] 一个多线程/多进程工具模块(生产者-消费者模式实现)
Language: Python - Size: 77.1 KB - Last synced at: about 1 month ago - Pushed at: about 4 years ago - Stars: 3 - Forks: 0

shutterstock/p-map-iterable
Performs a concurrent mapping with back pressure (won't iterate all source items if the consumer is not reading).
Language: TypeScript - Size: 604 KB - Last synced at: 12 days ago - Pushed at: 3 months ago - Stars: 2 - Forks: 0

orkhan-huseyn/blocking-queue
Implementation of a BlockingQueue in Java
Language: Java - Size: 9.77 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0

jessejcw/cpp_concurrent
Blocking ring buffer in C++11
Language: C++ - Size: 2.93 KB - Last synced at: 7 months ago - Pushed at: about 6 years ago - Stars: 2 - Forks: 3

ty7swkr/BlockingVector.Queue
blocking queue vs boost lockfree queue
Language: C++ - Size: 84 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 1 - Forks: 0

eMahtab/blocking-queue
Blocking Queue in Java
Size: 23.4 KB - Last synced at: about 2 months ago - Pushed at: 7 months ago - Stars: 1 - Forks: 0

isarandi/throttledpool
Parallel process pool that throttles the task producer thread to avoid out-of-memory issues
Language: Python - Size: 5.86 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 0

ismailfer/offheap-queue
OffHeap lists and queues, using Unsafe class, DirectByteBuffer, and Memory Mapped Files
Language: Java - Size: 35.2 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 0

Hacky-DH/cpputils
utils for cpp
Language: C++ - Size: 17.6 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

felipeek/c-fifo-blocking-queue
A FIFO blocking queue implemented in C.
Language: C - Size: 49.8 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 0

VictorGil/avenger-bot
Language: Java - Size: 25.4 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0

amarlearning/thread-pool-manager
Simple thread pool manager implemented in Java
Language: Java - Size: 2.93 KB - Last synced at: 3 months ago - Pushed at: almost 7 years ago - Stars: 1 - Forks: 0

nurzico/enqueue Fork of s5r3/enqueue
Another BlockingQueue implemented as ring buffer and aware of consumer
Language: Java - Size: 8.79 KB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 1 - Forks: 0

gireeshbharmshetty/java-message-queue
A simple, thread-safe, in-memory blocking message queue in Java.
Language: Java - Size: 3.91 KB - Last synced at: 12 days ago - Pushed at: 15 days ago - Stars: 0 - Forks: 0

vchernoy/concurrent
Monitor Synchronization in Examples
Language: Python - Size: 9.77 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 1

ekocbiyik/multithread-queue
multithrad tasks with BlockingDeque
Language: Java - Size: 55.7 KB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

siddhant-vij/Producer-Consumer-Problem-Java
Producer Consumer Problem
Language: Java - Size: 7.81 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

semercioglu1/FastFileExplorer
Fast File Explorer written in Java
Language: Java - Size: 70.3 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

NJdevPro/ConcurrentQueues
C++ thread safe queues
Language: C++ - Size: 13.7 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1

bishu21/ProducerAndConsumerQueue
Blocking Queue Implementation
Language: Java - Size: 2.93 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

flagsibh/jar-search
Aids to find a java class within JAR or ZIP files
Language: Java - Size: 43.9 KB - Last synced at: almost 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

MichalPula/JavaMultithreading
Project with examples covering threads, synchronization, locks, CompletableFuture, ExecutorService, Callable, Runnable and BlockingQueues
Language: Java - Size: 15.6 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

daggerok/java-queue-playground
java queue implementations
Language: Java - Size: 57.6 KB - Last synced at: 3 months ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

kamarros/multi-threading
Multi - thread learn. Add comment and .txt file about interface Runnable, Delayed and simple implementation.
Language: Java - Size: 97.7 MB - Last synced at: about 2 months ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

nealkumar/JBrew
The JBrew library collection is a set of of Java & JNI utility libraries featuring native facades that precisely tune elected garbage-collection sensitive operations for downstream consumers with use-cases hindered by the Java Memory Model. The library also seeks to abstract away syntax pitfalls in concurrency through its Task framework.
Language: Java - Size: 1.26 MB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 0 - Forks: 0

yichunzhao/blocking-queue-lock
creating a bounded-blocking queue using reentrant lock
Language: Java - Size: 64.5 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

yichunzhao/blocking-queue
using an intrinsic lock to create and demo a blocking queue
Language: Java - Size: 11.7 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

andor201995/work-async
Project to implement WorkerClass which execute task asynchronously
Language: Kotlin - Size: 134 KB - Last synced at: about 1 year ago - Pushed at: almost 5 years ago - Stars: 0 - Forks: 0

vicboma1/Redis-Native-Producer-Consumer
Redis C/C++ Producer Consumer
Language: C++ - Size: 198 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0

selfcompiler/Experiments
Here i do simple experiments in java for learning and Fun
Language: Java - Size: 62.5 KB - Last synced at: almost 2 years ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0

mtumilowicz/java11-concurrency-blockingqueue-producer-consumer-problem
Simple solution to producer - consumer problem using blocking queue.
Language: Java - Size: 64.5 KB - Last synced at: 3 months ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 1

phyunsj/node-red-simple-blocking-queue 📦
Node-RED a simple queue using Function Node
Size: 17.7 MB - Last synced at: 6 months ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

partizza/multiwriting
Example of The Producer Consumer Pattern
Language: Java - Size: 8.79 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 0 - Forks: 0

morad3741/MultithreadingExercises
Consumer/Producer with BlockingQueue
Language: Java - Size: 2.93 KB - Last synced at: 5 months ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0

philaporter/ubiquitous-barnacle
This project demonstrates using ArrayBlockingQueue for managing work on a queue between threads
Language: Java - Size: 856 KB - Last synced at: about 2 years ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0

samdwar/ThreadPool
Implementing Thread Pool in Java
Language: Java - Size: 1000 Bytes - Last synced at: almost 2 years ago - Pushed at: over 8 years ago - Stars: 0 - Forks: 0

msb-public/hippo4j
Hippo-4J 通过对 JDK 线程池增强,以及扩展三方框架底层线程池等功能,为业务系统提高线上运行保障能力
Language: Java - Size: 62.2 MB - Last synced at: over 1 year ago - Stars: 0 - Forks: 0