Kafka-based Job Queue for Python

Practical multithreading tutorials. Languages supported: C++, Java, C#, Python, Javascript/Nodejs.

Golang Kafka consumer and producer example

redisqueue provides a producer and consumer of a queue that uses Redis streams

Small Flask app with scalable, asynchronous backend workers deployed on Kubernetes.

a Python voice chat app that uses WebSockets to send encrypted data between a multi-threaded client and server

Distributed task redisqueue(最简单python分布式函数调度框架)

consumer/producer/rpc library built over aioamqp

Using NATS Jetstream as queue manager to replace RabbitMQ, etc.

It can flexibly control async task, ignore the order of sending and receiving, allow binding of asynchronous tasks in pending state, and support producer consumer mode and order mode

A producer-consumer solution for Golang

A synchronized persistent Queue class

A tutorial on building a real-time data streaming application pipeline with Apache Kafka🔥🔥🔥

Lightweight Module for Asynchronous Event Driven Systems

Producer-consumer problem solution using semaphore and mutex

Efficient Pandas and Ray Kafka Producer for python using actor model.

It will take backup of given topic and store that into either local filesystem or S3.It will also restore from given local filesystem or S3.

Producer-consumer problem visualization

📈 Multithreaded Stock Price Simulator built in C++ with Producer–Consumer concurrency, thread-safe queues, and a React frontend for real-time stock visualization.The frontend consumes this data over WebSockets and displays it with interactive charts.

Julia Channels with defined length: Buffered and threaded iterators for machine learning.

Process synchronization, Deadlock avoidance and Disk scheduling algorithms implemented in Java.

A TPL Dataflow-compatible ISourceBlock supporting priority queueing

Event Bus asynchronous queuing with many Producer and Consumer implementations

C#.NET based DevFast NuGet package

Home automation interface based on Arduino, UARTs and CAN transceivers.

In order to deploy Confluent Kafka in the machine, the project starts 4 Docker containers (ZooKeeper, Kafka, Kafka-REST-Proxy and Kafka-Topics-UI). It also starts 3 other containers (1 Producer and 2 Consumers) to emulate message publish/consume using crypto currencies JSON data.

NiFi processor emulating queue/topic patterns on top of Redis

A Zephyr producer consumer app. - An HDLC link over UART streaming sinwave samples and a Zephyr application consuming them - zephyr rtos, stm32f4, protobuf, nanopb, HDLC, threads

Programming with C course: pointer, multi-process, multi-thread, concurrency, semaphores, Socket, PIPE, FIFO

Example of using QSharedMemory across C++ and Python in a producer/consumer problem