GitHub topics: blocking-queue
terry960302/concurrent-entity-change-logger
멀티스레드 환경에서 JPA 엔티티 변경 사항을 감지하고, 외부 인프라 없이 안전하게 비동기 저장하는 구조입니다. 부하를 줄이기 위한 JDBC Batch Insert, 로그 유실을 막기 위한 WAL 파일 로깅 처리, 동시성 처리를 위한 Queue 처리 등을 포함하고 있습니다.
Language: Java - Size: 1.92 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 0 - Forks: 0

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: 3 days ago - Pushed at: 4 months ago - Stars: 5,816 - Forks: 1,221

ZaTribune/assets-matching-engine
A demo project for an assets matching engine.
Language: Java - Size: 453 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 0 - Forks: 0

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

ty7swkr/BlockingQueue-based-on-vector
High-performance BlockingQueue based on std::vector in c++11
Language: C++ - Size: 115 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

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

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

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

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

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: 9 days ago - Pushed at: 4 months ago - Stars: 2 - Forks: 0

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

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

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

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

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

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

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

ekocbiyik/multithread-queue
multithrad tasks with BlockingDeque
Language: Java - Size: 55.7 KB - Last synced at: 3 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: 4 months ago - Pushed at: over 1 year ago - Stars: 0 - 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: 3 months ago - Pushed at: about 2 years ago - Stars: 1 - 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

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

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

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: 3 months ago - Pushed at: almost 4 years ago - Stars: 0 - 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: over 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

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

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

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: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 0

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

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

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

bishu21/ProducerAndConsumerQueue
Blocking Queue Implementation
Language: Java - Size: 2.93 KB - Last synced at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - 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: over 2 years ago - Pushed at: about 7 years ago - Stars: 1 - Forks: 0

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

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

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

yichunzhao/blocking-queue-lock
creating a bounded-blocking queue using reentrant lock
Language: Java - Size: 64.5 KB - Last synced at: over 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: over 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

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

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

codepumpkin/DesignPatterns
Code repository for all the articles on design patterns at codepumpkin.com
Language: Java - Size: 37.1 KB - Last synced at: 6 days ago - Pushed at: over 5 years ago - Stars: 5 - Forks: 10

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: about 5 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: about 4 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

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: 4 months ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 1

VictorGil/avenger-bot
Language: Java - Size: 25.4 KB - Last synced at: over 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: 4 months ago - Pushed at: almost 7 years ago - Stars: 1 - Forks: 0

alikilickaya/job-management
A simple Job Management Service prototype
Language: Java - Size: 72.3 KB - Last synced at: 26 days ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0

partizza/multiwriting
Example of The Producer Consumer Pattern
Language: Java - Size: 8.79 KB - Last synced at: about 2 years 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: over 2 years ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 0
