-
封装了常用的生产者-消费者模型，自定义消费者只需覆盖consume方法(关心逻辑实现)，支持有锁(有界)队列和无锁(有界队列)，无锁(CAS)队列支持阻塞、循环以及自旋策略。
-
消费者池：优先使用SPSC模型，如果生产者过多，那么多出的生产者使用MPMC模型。
seaswalker / Consumer
Licence: other
封装常用的生产者-消费者模型
Stars: ✭ 16
Programming Languages
java
68154 projects - #9 most used programming language
Labels
Projects that are alternatives of or similar to Consumer
Swadeshi
Implementing a Web Based solution through which farmers can participate in a commodity exchange market
Stars: ✭ 21 (+31.25%)
Mutual labels: consumer
standards-maintenance
This repository houses the interactions, consultations and work management to support the maintenance of baselined components of the Consumer Data Right API Standards and Information Security profile.
Stars: ✭ 32 (+100%)
Mutual labels: consumer
rocketmq
RocketMQ client for go supportting producer and consumer.
Stars: ✭ 29 (+81.25%)
Mutual labels: consumer
aws-kinesis-consumer
Consume an AWS Kinesis Data Stream to look over the records from a terminal.
Stars: ✭ 23 (+43.75%)
Mutual labels: consumer
Confluent Kafka Go
Confluent's Apache Kafka Golang client
Stars: ✭ 3,047 (+18943.75%)
Mutual labels: consumer
Insulator
A client UI to inspect Kafka topics, consume, produce and much more
Stars: ✭ 53 (+231.25%)
Mutual labels: consumer
rabbitmq-consumer
A configurable RabbitMQ consumer made in Rust, useful for a stable and reliable CLI commands processor.
Stars: ✭ 25 (+56.25%)
Mutual labels: consumer
Spark
Apache Spark is a fast, in-memory data processing engine with elegant and expressive development API's to allow data workers to efficiently execute streaming, machine learning or SQL workloads that require fast iterative access to datasets.This project will have sample programs for Spark in Scala language .
Stars: ✭ 55 (+243.75%)
Mutual labels: consumer
youtube-dl-nas
youtube download queue websocket server with login for private NAS.
Stars: ✭ 136 (+750%)
Mutual labels: consumer
ember-contextual-services
Services in Ember are scoped to the app as a whole and are singletons. Sometimes you don't want that. :) This addon provides ephemeral route-based services.
Stars: ✭ 20 (+25%)
Mutual labels: consumer
php-kafka-lib
PHP Kafka producer / consumer library with PHP Avro support, based on php-rdkafka
Stars: ✭ 38 (+137.5%)
Mutual labels: consumer
node-bunnymq
BunnyMQ is an amqp.node wrapper to ease common AMQP usages (RPC, pub/sub, channel/connection handling etc.).
Stars: ✭ 20 (+25%)
Mutual labels: consumer
awesome-contract-testing
Awesome resources for Consumer-Driven Contract Testing
Stars: ✭ 54 (+237.5%)
Mutual labels: consumer
pulsar-flex
Pulsar Flex is a modern Apache Pulsar client for Node.js, developed to be independent of C++.
Stars: ✭ 43 (+168.75%)
Mutual labels: consumer
codeigniter-queue-worker
CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller
Stars: ✭ 67 (+318.75%)
Mutual labels: consumer
amqpextra
Golang AMQP on steroids. Reliable connection. Publisher. Consumer.
Stars: ✭ 59 (+268.75%)
Mutual labels: consumer
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].