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

Topic: "worker-queue"

Automattic/kue

Kue is a priority job queue backed by redis, built for node.js.

Language: JavaScript - Size: 6.13 MB - Last synced at: about 4 hours ago - Pushed at: over 1 year ago - Stars: 9,467 - Forks: 868

bee-queue/bee-queue

A simple, fast, robust job/task queue for Node.js, backed by Redis.

Language: JavaScript - Size: 4.92 MB - Last synced at: 19 days ago - Pushed at: 21 days ago - Stars: 3,926 - Forks: 222

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced at: 18 days ago - Pushed at: over 3 years ago - Stars: 570 - Forks: 23

actumn/celery.node

Celery task queue client/worker for nodejs

Language: TypeScript - Size: 915 KB - Last synced at: 17 days ago - Pushed at: about 1 year ago - Stars: 298 - Forks: 75

yoomoney/db-queue 📦

Worker-queue implementation on top of Java and database

Language: Java - Size: 850 KB - Last synced at: 5 months ago - Pushed at: about 3 years ago - Stars: 233 - Forks: 46

DumbMachine/nq

Cancellable, Efficient and Reliable Distributed Task Queue in Go

Language: Go - Size: 3.64 MB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 93 - Forks: 4

changhuixu/rabbitmq-labs

The source code for my RabbitMQ tutorials.

Language: C# - Size: 1.15 MB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 67 - Forks: 51

mugli/orkid-node

Reliable and modern Redis Streams based task queue for Node.js 🤖

Language: JavaScript - Size: 1.95 MB - Last synced at: 12 days ago - Pushed at: over 2 years ago - Stars: 63 - Forks: 10

conveyor-mq/conveyor-mq

A fast, robust and extensible distributed task/job queue for Node.js, powered by Redis.

Language: TypeScript - Size: 2.74 MB - Last synced at: 16 days ago - Pushed at: 6 months ago - Stars: 50 - Forks: 3

jczic/MicroWorkers

A micro workers class that easily manages a pool of threads to optimise simultaneous jobs and jobs endings, for MicroPython (used on Pycom modules & ESP32)

Language: Python - Size: 61.5 KB - Last synced at: about 2 months ago - Pushed at: over 5 years ago - Stars: 47 - Forks: 12

atayahmet/storage-based-queue 📦

Javascript queue library with persistent storage based queue mechanism for the browsers environments. Specially designed for offline.

Language: JavaScript - Size: 1.71 MB - Last synced at: 11 days ago - Pushed at: about 4 years ago - Stars: 43 - Forks: 5

Joker666/cogman

Simple, efficient background processing for Golang backed by RabbitMQ and Redis

Language: Go - Size: 225 KB - Last synced at: about 1 month ago - Pushed at: almost 3 years ago - Stars: 41 - Forks: 7

zaiste/blezer

:confetti_ball: :battery: Simple background job/task processing queue for Node.js (>= 7.6) using `cluster` & separate Node processes.

Language: JavaScript - Size: 602 KB - Last synced at: 9 days ago - Pushed at: over 2 years ago - Stars: 16 - Forks: 5

martianboy/peanar

A job queue for Node.js based on RabbitMQ

Language: TypeScript - Size: 2.55 MB - Last synced at: 5 days ago - Pushed at: about 1 month ago - Stars: 9 - Forks: 4

KnisterPeter/queue-ts 📦

A promise based worker queue with limited concurrency

Language: TypeScript - Size: 2.65 MB - Last synced at: 22 days ago - Pushed at: over 1 year ago - Stars: 9 - Forks: 5

calebboyd/redis-x-stream

An AsyncIterable interface for reading redis streams

Language: TypeScript - Size: 1.67 MB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 9 - Forks: 4

bnkamalesh/routinepool

A minimalistic Go package to setup a worker pool which accepts functions of signature `fn()` [not maintained]

Language: Go - Size: 14.6 KB - Last synced at: 2 months ago - Pushed at: about 6 years ago - Stars: 5 - Forks: 2

iflamed/mfworker

A memory and file based task worker for Golang. Queue jobs only for single process application.

Language: Go - Size: 31.3 KB - Last synced at: 3 months ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 0

aloknerurkar/task-runner

Async task runner in go

Language: Go - Size: 10.7 KB - Last synced at: 3 months ago - Pushed at: almost 8 years ago - Stars: 4 - Forks: 0

michaelbironneau/queue

Golang worker queues backed by a cloud service such as Azure Service Bus.

Language: Go - Size: 6.84 KB - Last synced at: almost 2 years ago - Pushed at: about 8 years ago - Stars: 4 - Forks: 1

ivanvs/pidginmq

PidginMQ is a job queu and task scheduling library for Node.js and JavaScript, built on PostgreSQL.

Language: TypeScript - Size: 1.07 MB - Last synced at: 2 months ago - Pushed at: 9 months ago - Stars: 3 - Forks: 0

cookiemonsterproject/cookie-monster

A flexible worker pool that aims to fit all possible use-cases.

Language: Go - Size: 84 KB - Last synced at: 9 months ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 2

stardogventures/dropwizard-worker

Simple asynchronous processing for Dropwizard, using SQS

Language: Java - Size: 34.2 KB - Last synced at: 2 months ago - Pushed at: about 6 years ago - Stars: 3 - Forks: 2

MiguelCastillo/workit

JavaScript utility for managing child processes in node

Language: JavaScript - Size: 45.9 KB - Last synced at: about 1 month ago - Pushed at: over 7 years ago - Stars: 3 - Forks: 0

nextorigin/el-borracho-ui

Realtime Web UI for Bull job queue that pulls from El Borracho REST+SSE API

Language: CoffeeScript - Size: 207 KB - Last synced at: 16 days ago - Pushed at: almost 8 years ago - Stars: 3 - Forks: 0

khauser/MQJsonRPCWorker

Exemplary ansynchronous client-server communication layer through JsonRPC on a RabbitMQ Worker implementation

Language: Java - Size: 219 KB - Last synced at: over 2 years ago - Pushed at: almost 10 years ago - Stars: 3 - Forks: 0

almic/nque

Simple job queue and worker processing for Node.js with Redis

Language: JavaScript - Size: 40 KB - Last synced at: 22 days ago - Pushed at: about 7 years ago - Stars: 2 - Forks: 1

syrnxalno/pixcrate

Distributed queue system for image processing using Node.js, BullMQ, Sharp and Redis

Language: JavaScript - Size: 384 KB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 1 - Forks: 0

rulyotano/example-queue-workers

Sample project to create a message queue to process long running tasks

Language: C# - Size: 325 KB - Last synced at: 27 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

Ghoti-io/Pool

Pool is a C++ worker queue thread pool, implemented as an installable library on Linux.

Language: C++ - Size: 520 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 0

xxl4tomxu98/django_redis_celery

Django web server using Celery server to handle asynchronous tasks by using Redis as a message Broker

Language: Python - Size: 41 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0

Captain-ALM/CALM-Worker-Pump

Allows for processing and instruction execution to be performed on a different thread to the main winforms thread.

Language: Visual Basic .NET - Size: 20.5 KB - Last synced at: about 2 years ago - Pushed at: almost 4 years ago - Stars: 1 - Forks: 0

smokezl/go-worker-pool

Language: Go - Size: 6.84 KB - Last synced at: 12 months ago - Pushed at: almost 6 years ago - Stars: 1 - Forks: 0

woeye/elixir-rabbitmq-python-test

Proof of concept code for using Elixir as a multiplexer for Python based workers

Language: Elixir - Size: 16.6 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0

Kiosked/handlr 📦

Job queue and handler for NodeJS

Language: JavaScript - Size: 126 KB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 1 - Forks: 0

bobbrady/promise-job-queue

A concurrency limited job queue utilizing ES6 promises.

Language: JavaScript - Size: 19.5 KB - Last synced at: 17 days ago - Pushed at: about 7 years ago - Stars: 1 - Forks: 0

nextorigin/el-borracho

Express 4 router containing a REST and SSE API for Bull job queues

Language: CoffeeScript - Size: 197 KB - Last synced at: 9 days ago - Pushed at: almost 8 years ago - Stars: 1 - Forks: 0

mdbottino/go-worker-queue-implementation

Basic implementation of a worker queue using go channels

Language: Go - Size: 2.93 KB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 0 - Forks: 0

rsubr/pgwq

Worker queue built using Postgres

Language: PLpgSQL - Size: 5.86 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

dominioncfg/mass-transit-demos

Examples of principal messaging flows and concepts within MassTransit library using RabbitMq

Language: C# - Size: 48.8 KB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

dominioncfg/rabbit-mq-tests

Examples of principal messaging flows and concepts within RabbitMq using C#

Language: C# - Size: 16.6 KB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

zlikavac32/beanstalkd-lib-bundle

Bundle for zlikavac32/beanstalkd-lib

Language: PHP - Size: 638 KB - Last synced at: 4 months ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

itsjithinv/message-bus

Example implementation of Message-Bus in a web application

Language: PHP - Size: 2.93 KB - Last synced at: 6 months ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

TidalPaladin/twitlib

Python library for Twitter automation via streaming APIs

Language: Python - Size: 176 KB - Last synced at: 7 months ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 0

shekhar-kamble/golang-rmqp-worker-autoscaler

auto-scale the workers according to the no of messages in the corresponding queue

Language: Go - Size: 4.88 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 0 - Forks: 0

kuhnuri/kuhnuri-queue

Kuhnuri queue specification and reference implementation

Language: Scala - Size: 1.14 MB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

tomahawkphp/queue

Tomahawk Worker Queue

Language: PHP - Size: 59.6 KB - Last synced at: 6 months ago - Pushed at: about 8 years ago - Stars: 0 - Forks: 0