An open API service providing repository metadata for many open source software ecosystems.

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

Related Topics