2 dépôts
Awesome GitHub RepositoriesQueue Shutdowns
Operations that interrupt all waiting fibers, empty the queue, and cause future operations to terminate immediately.
Distinct from Queue Wait Timeouts: Distinct from Queue Wait Timeouts: covers immediate forceful shutdown of a queue, not time-based cancellation of individual tasks.
Explore 2 awesome GitHub repositories matching devops & infrastructure · Queue Shutdowns. Refine with filters or upvote what's useful.
Awesome Queue Shutdowns GitHub Repositories
Trouvez les meilleurs dépôts grâce à l'IA.Nous recherchons les dépôts les plus pertinents grâce à l'IA.
- automattic/kue
Automattic/kue
9,437Voir sur GitHubKue is a Redis-backed job queue library for Node.js that provides a complete system for defining, scheduling, and processing background work. It stores job metadata and state in Redis lists and sorted sets, enabling persistent, in-memory operations with configurable concurrency control and priority-sorted processing. The library includes a RESTful HTTP API for managing jobs and a web-based monitoring dashboard for inspecting job status, progress, and logs. The system distinguishes itself through its event-driven worker model, where workers listen for job events via Redis pub/sub and process j
Shuts down the job queue gracefully by passing a timeout duration before the callback.
JavaScriptjob-queuepriority-queueworker-queue - zio/zio
zio/zio
4,347Voir sur GitHubZIO is a functional effect system for the JVM that models asynchronous and concurrent programs as pure, composable values with typed error handling and dependency injection. Its core identity is built on fiber-based concurrency, where lightweight, non-blocking fibers execute millions of concurrent tasks with structured lifecycle management, and a dual-channel error model that separates expected business failures from unexpected system defects at compile time. The system provides effect-typed dependency injection through a layer-based dependency graph, pull-based reactive stream processing with
ZIO interrupts all fibers waiting on a queue, empties it, and causes future operations to terminate immediately.
Scalaasynchronicityasynchronousasynchronous-programming
