blockingqueue

Disruptor BlockingQueue

基于 kotlin Channel 的优先级异步任务队列

通过阻塞队列和延时队列，实现在非延时情况以及延时情况下的生产者消费者模式

学习大数据的练习和笔记

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.

A multithreaded airport simulated in Java using BlockingQueue.

Java Examples --- Threads, Executor Framework,Fork Join Framework,CompletableFuture

Este projeto demonstra duas abordagens distintas para o processamento de arquivos de texto em Java, com foco em paralelismo e desempenho. Ideal para aplicações que precisam lidar com grandes volumes de dados, o projeto mostra como dividir o trabalho entre múltiplas threads de forma eficiente.

Program Java yang mensimulasikan sistem restoran menggunakan multi-threading dengan tiga peran utama (Waiter, Chef, Cashier) dan mekanisme sinkronisasi untuk mencegah konflik data.

a Blocking Queue to be used in a multi threaded environment which keeps the order within the partition

Yet another .Net 2.0 Blocking Queue implementation

A java application with multi-threading and shared memory inter process communication

Unacademy Assignment: A Service Worker to fetch images async (uses: Executors.newSingleThreadExecutor, Handler, LinkedBlockingQueue)

Multi-threaded Java pipeline that processes 10.6M rows of OULAD student click data using producer-consumer concurrency with BlockingQueue, ConcurrentHashMap, and poison pill termination. Generates per-course daily click summaries and threshold-based activity reports.

Concurrent Task Execution Engine built using Java Multithreading, Executor Framework, and Producer-Consumer architecture with real-time metrics and retry system.