producer-consumer
There are 403 repositories under producer-consumer topic.
joowani/kq
Kafka-based Job Queue for Python
vsouza/go-kafka-example
Golang Kafka consumer and producer example
robinjoseph08/redisqueue
redisqueue provides a producer and consumer of a queue that uses Redis streams
thanhit95/multi-threading
Practical multithreading tutorials. Languages supported: C++, Java, C#, Python, Javascript/Nodejs.
matiaslindgren/celery-kubernetes-example
Small Flask app with scalable, asynchronous backend workers deployed on Kubernetes.
abo123456789/leek
Distributed task redisqueue(最简单python分布式函数调度框架)
sspathak/VoiceChat
a Python voice chat app that uses WebSockets to send encrypted data between a multi-threaded client and server
TNT-03/async-task-mapping
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
aio-libs/aioamqp_consumer
consumer/producer/rpc library built over aioamqp
jiacai2050/prosumer
A producer-consumer solution for Golang
balena/python-pqueue
A synchronized persistent Queue class
1995parham/saf
Using NATS Jetstream as queue manager to replace RabbitMQ, etc.
firebase007/kafka_producer_consumer_tutorial
A tutorial on building a real-time data streaming application pipeline with Apache Kafka🔥🔥🔥
eventifyio/eventify
Lightweight Module for Asynchronous Event Driven Systems
codophobia/producer-consumer-problem-solution-in-c
Producer-consumer problem solution using semaphore and mutex
ujjawal-khare-27/ray-kafka-producer
Efficient Pandas and Ray Kafka Producer for python using actor model.
116davinder/apache-kafka-backup-and-restore
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.
baggepinnen/LengthChannels.jl
Julia Channels with defined length: Buffered and threaded iterators for machine learning.
iximiuz/producer-consumer-vis
Producer-consumer problem visualization
kevdever/TPLDataflowHelpers_PriorityBufferBlock
A TPL Dataflow-compatible ISourceBlock supporting priority queueing
Showndarya/Operating-System-Algorithms
Process synchronization, Deadlock avoidance and Disk scheduling algorithms implemented in Java.
wagnerjfr/springboot-crypto-kafka-docker
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.
akouz/HBus
Home automation interface based on Arduino, UARTs and CAN transceivers.
PHPMessageBus/eventbus-queue
Event Bus asynchronous queuing with many Producer and Consumer implementations
samaysar/dotdotnet
C#.NET based DevFast NuGet package
javajefe/nifi-redis-pubsub-bundle
NiFi processor emulating queue/topic patterns on top of Redis
FLombardi-PhD/C-teaching
Programming with C course: pointer, multi-process, multi-thread, concurrency, semaphores, Socket, PIPE, FIFO
iamibr/ApachePulsar-SpringBoot
Apache Pulsar in Spring Boot
abhinav-bohra/Producer-Consumer-System
Implementation of multiple producer-consumer system where producers create prioritized jobs
brunocampos01/programacao-paralela-e-distribuida
Aulas e exercícios da matéria: Programação Paralela e Distribuída (INE5645) e Computação Distribuida (INE5625).
CodeFinder2/shared-memory-pycpp-example
Example of using QSharedMemory across C++ and Python in a producer/consumer problem
kuanhungchen/Fall-2019-Operating-Systems
🔄 A thread switching package which targets at Edsim51 simulator.
Amit3200/SE-Designs-Understanding
Contains various design strategies with the implementation of them on a small level with an example. This repo helps us to understand how and why one should implement various designs while creating applications.
firebase007/logRocket-rabbit-tutorial
Send Messages and consumer messages from a queue using RabbitMQ - a highly performant message broker
TSMotter/zpc
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