awesome-repositories.com
博客
awesome-repositories.com

通过 AI 驱动的搜索,发现最优秀的开源仓库。

探索精选搜索开源替代品自托管软件博客网站地图
项目关于排名机制媒体报道MCP 服务器
法律隐私政策服务条款
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
·

46 个仓库

Awesome GitHub RepositoriesTask Queues

Systems for grouping and organizing background tasks into named queues for managed execution.

Distinguishing note: Focuses on logical grouping of tasks into named queues for environment or priority isolation.

Explore 46 awesome GitHub repositories matching devops & infrastructure · Task Queues. Refine with filters or upvote what's useful.

Awesome Task Queues GitHub Repositories

用 AI 发现最棒的仓库。我们将通过 AI 为您搜索最匹配的仓库。
  • paperless-ngx/paperless-ngxpaperless-ngx 的头像

    paperless-ngx/paperless-ngx

    42,172在 GitHub 上查看↗

    Paperless-ngx is a self-hosted document management server designed to transform physical paperwork into a searchable, organized digital archive. It functions as a private platform for storing, indexing, and retrieving documents, providing users with full control over their data on local infrastructure or private cloud servers. The system distinguishes itself through an automated workflow engine that categorizes, tags, and routes incoming files using content analysis and metadata extraction. To maintain responsiveness during resource-intensive tasks like optical character recognition, it utili

    Handles resource-intensive document parsing and OCR tasks asynchronously to maintain interface responsiveness.

    Pythonangulararchivingdjango
    在 GitHub 上查看↗42,172
  • junkfood02/sealJunkFood02 的头像

    JunkFood02/Seal

    26,953在 GitHub 上查看↗

    Seal is a mobile application designed to retrieve video and audio content from various online platforms. It functions as a graphical interface that manages background transfer processes, allowing users to download and archive media files directly to their local device storage for offline access. The application distinguishes itself by acting as a bridge to powerful command-line utilities, orchestrating these external binaries to handle complex media extraction and file conversion tasks. Users can customize their experience through a declarative template system that defines specific execution

    Manages concurrent download operations by scheduling and monitoring multiple background worker processes through a centralized task manager.

    Kotlinandroidf-droidjetpack-compose
    在 GitHub 上查看↗26,953
  • archivebox/archiveboxArchiveBox 的头像

    ArchiveBox/ArchiveBox

    26,876在 GitHub 上查看↗

    ArchiveBox is a self-hosted archiving tool designed for personal digital preservation and research data management. It functions as an automated web preservation engine that monitors URL inputs from bookmarks, browser history, or manual entries to capture and store permanent, offline copies of web content. By utilizing headless browser automation, the system renders dynamic web pages to ensure that captured snapshots, PDFs, and media assets remain accurate and accessible even if the original source disappears. The project distinguishes itself through a modular extractor pipeline and a task-qu

    Manages long-running archiving jobs by distributing ingestion tasks across background workers to ensure reliable and scalable content capture.

    Pythonarchiveboxbackupsbookmark-archiver
    在 GitHub 上查看↗26,876
  • apify/crawleeapify 的头像

    apify/crawlee

    24,002在 GitHub 上查看↗

    Crawlee is a web scraping framework designed for building scalable, reliable, and distributed data extraction pipelines. It provides a unified interface for managing headless browser automation and lightweight HTTP requests, allowing developers to handle complex web navigation, dynamic content rendering, and large-scale data collection within a single, modular architecture. The project distinguishes itself through its resource-aware concurrency controller, which dynamically scales task execution based on real-time CPU and memory usage to prevent host machine exhaustion. It also features a rob

    Organizes URLs into dynamic queues to facilitate systematic site traversal and prevent duplicate processing.

    TypeScriptapifyautomationcrawler
    在 GitHub 上查看↗24,002
  • voltagent/awesome-claude-code-subagentsVoltAgent 的头像

    VoltAgent/awesome-claude-code-subagents

    21,906在 GitHub 上查看↗

    This project provides a framework for managing multi-agent systems, designed to automate complex software development, infrastructure, and business workflows. It functions as a multi-agent workflow orchestrator that routes tasks to domain-specific workers while maintaining state persistence and infrastructure automation. By leveraging large language models, the system decomposes high-level objectives into actionable plans, ensuring that complex operations are executed with consistency and reliability. The framework distinguishes itself through its hierarchical agent registry and policy-driven

    Organizes work into prioritized queues with support for batching, retries, and dead-letter handling.

    Shellai-agent-frameworkai-agent-toolsai-agents
    在 GitHub 上查看↗21,906
  • temporalio/temporaltemporalio 的头像

    temporalio/temporal

    18,411在 GitHub 上查看↗

    Temporal is a distributed workflow orchestration engine designed to manage fault-tolerant, stateful, and long-running background processes. It functions as a platform for coordinating complex cross-service operations, ensuring consistency and reliability in distributed environments by decoupling workflow orchestration from task execution. The platform distinguishes itself through a deterministic, event-sourced execution model that reconstructs workflow state by re-executing code from an immutable event log. This approach isolates non-deterministic side effects into managed activities, allowin

    Manages the distribution of work across worker pools to ensure balanced processing and throughput.

    Gocronjob-schedulerdistributed-crondistributed-systems
    在 GitHub 上查看↗18,411
  • graphql/dataloadergraphql 的头像

    graphql/dataloader

    13,380在 GitHub 上查看↗

    DataLoader is a utility that collects individual data loads into a single batch and caches results to minimize redundant backend requests. It operates on a batch-and-cache architecture, where multiple data lookups within a single execution frame are grouped together and dispatched as one request, with the results stored in memory for instant retrieval on subsequent calls. The utility distinguishes itself through several key capabilities. It supports per-key error handling, allowing partial failures within a batch without rejecting the entire operation. A cache priming mechanism lets developer

    Controls when batched loads are dispatched through custom schedulers for manual or delayed execution.

    JavaScriptbatchdataloadergraphql
    在 GitHub 上查看↗13,380
  • pingdotgg/t3codepingdotgg 的头像

    pingdotgg/t3code

    12,671在 GitHub 上查看↗

    t3code is a platform for operating AI coding agents through a web interface to develop and maintain software projects. It functions as an orchestrator that manages AI agent lifecycles and communication, providing a system for provisioning isolated remote development environments and managing secure connections to cloud-hosted resources. The project utilizes an event-sourced backend architecture that processes typed commands into persisted domain events to maintain system state. It employs a communication system based on JSON-RPC over WebSockets to synchronize real-time state and events betwee

    Utilizes queue-backed workers to process long-running background flows and maintain deterministic synchronization.

    TypeScript
    在 GitHub 上查看↗12,671
  • nasa/fprimenasa 的头像

    nasa/fprime

    10,766在 GitHub 上查看↗

    F Prime 是一个基于组件的框架,专为嵌入式和航天软件的开发与部署而设计。它提供了一种模块化架构,将软件逻辑与通信接口解耦,允许开发者通过领域特定建模语言定义系统结构。这种基于模型的方法支持自动化代码生成,在确保复杂系统拓扑一致性的同时,维护了软件模块之间严格的接口契约。 该框架的特色在于其集成的构建系统和地面数据操作套件。它实现了嵌入式软件全生命周期的自动化,从交叉编译和依赖管理到遥测与命令接口的生成。通过为机载飞行软件和地面监控提供统一的环境,它促进了跨不同硬件平台的分布式嵌入式系统的无缝集成、测试及指挥控制。 除了核心架构外,该项目还包含用于系统可观测性的综合工具,包括实时遥测可视化、事件日志记录和诊断追踪。它支持从裸机环境到实时操作系统的多种部署场景,并提供了内存管理、状态驱动行为建模和异步任务执行机制。 该项目以 C++ 仓库形式维护,并提供详尽的文档和支持跨平台开发的构建系统。

    Configures message queue sizes for active components to manage task priorities and handle inter-component communication traffic effectively.

    C++componentscppembedded
    在 GitHub 上查看↗10,766
  • jeasonlzy/okhttp-okgojeasonlzy 的头像

    jeasonlzy/okhttp-OkGo

    10,571在 GitHub 上查看↗

    OkHttp-OkGo is a network request framework that wraps OkHttp to simplify the process of sending and receiving data from web services. It provides a structured system for managing asynchronous data streams and concurrency through integration with RxJava. The project includes dedicated managers for batch file transfers, enabling the simultaneous upload and download of multiple files. The download system supports breakpoint-based management, allowing interrupted transfers to be paused and resumed from the last saved position. Additional capabilities include a custom HTTP cache manager for defin

    Includes a task queueing system to organize sequential or simultaneous network execution.

    Javahttpokgookhttp
    在 GitHub 上查看↗10,571
  • easydiffusion/easydiffusioneasydiffusion 的头像

    easydiffusion/easydiffusion

    10,398在 GitHub 上查看↗

    Easy Diffusion is a desktop application that generates images from text descriptions using AI. It provides a straightforward interface for creating visuals by simply typing what you want to see, with the ability to preview images as they are being generated. The application supports loading custom AI models, allowing users to switch between different artistic capabilities and styles. It includes tools for editing existing images through text prompts or masks, applying predefined artistic styles like "Realistic" or "Pencil Sketch", and upscaling or correcting facial details after generation. F

    Adds several image generation requests to a queue so they run sequentially without manual intervention.

    JavaScriptartdiffusiongenerative-art
    在 GitHub 上查看↗10,398
  • kubernetes/client-gokubernetes 的头像

    kubernetes/client-go

    9,837在 GitHub 上查看↗

    This project is a Go language library that provides a programmatic interface for interacting with the Kubernetes API server. It serves as a client for managing cluster resources, offering both typed interfaces for compile-time safety and dynamic interfaces for unstructured data and custom resource management. The library includes a controller framework designed for building event-driven automation. This framework utilizes informers to maintain local resource caches and rate-limited work queues to decouple event detection from state reconciliation. High availability is supported through a lead

    Implements rate-limited work queues to decouple resource event detection from state reconciliation.

    Gok8s-staging
    在 GitHub 上查看↗9,837
  • agenda/agendaagenda 的头像

    agenda/agenda

    9,679在 GitHub 上查看↗

    Agenda is a persistent background job scheduler and distributed task runner for Node.js applications. It functions as a cron job manager and task queue that ensures background processes survive application restarts by storing job state and metadata in a database. The system coordinates execution across multiple worker instances using distributed locking mechanisms to prevent duplicate processing. It supports flexible scheduling via cron expressions or specific dates and includes a pluggable storage interface for backends such as MongoDB, PostgreSQL, and Redis. The platform provides controls

    Leverages MongoDB to persist job metadata and manage distributed locking for task execution.

    HTMLautomatedcroncronjob
    在 GitHub 上查看↗9,679
  • resque/resqueresque 的头像

    resque/resque

    9,480在 GitHub 上查看↗

    Resque is a Ruby library for enqueueing and processing asynchronous tasks using Redis as a data store. It functions as a distributed task processor and queue manager, allowing long-running work to be moved out of the main request cycle. The system executes background jobs in isolated child processes to prevent memory leaks and provides a web-based dashboard for monitoring queue depths, worker activity, and failed job statistics. Capability areas include distributed worker coordination via signals, error handling with job retry mechanisms, and priority-ordered queue management. It also suppor

    Runs background workers that poll Redis queues and execute jobs within isolated child processes.

    Rubyasynchronous-tasksasynctaskbackground-jobs
    在 GitHub 上查看↗9,480
  • automattic/kueAutomattic 的头像

    Automattic/kue

    9,437在 GitHub 上查看↗

    Kue 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
    在 GitHub 上查看↗9,437
  • microsoft/ufomicrosoft 的头像

    microsoft/UFO

    9,017在 GitHub 上查看↗

    UFO is a multi-device task orchestrator and LLM agent orchestration framework designed to decompose natural language requests into executable task graphs. It functions as a cross-platform UI automation tool capable of performing interactions on Windows and mobile devices while routing tasks to distributed agents based on their hardware and software capabilities. The system is distinguished by its RAG-enhanced agent architecture, which integrates external documentation and previous execution traces to improve decision-making. It employs a hybrid UI detection approach that combines computer vis

    Implements queues to hold tasks for busy devices until they become idle.

    Pythonagentautomationcopilot
    在 GitHub 上查看↗9,017
  • johnserf-seed/tiktokdownloadJohnserf-Seed 的头像

    Johnserf-Seed/TikTokDownload

    8,673在 GitHub 上查看↗

    TikTokDownload is a configurable batch video downloader for TikTok and Douyin that strips watermarks and supports automated downloads from user profiles, likes, and collections. It functions as a social media content archiving tool, enabling users to download videos and audio from these platforms for offline viewing or personal backup. The project distinguishes itself through a modular download pipeline that combines audio extraction, batch scheduling, config-driven workflows, cookie-based authentication, URL parsing, paginated API scraping, and watermark removal. It uses a settings file to c

    Implements a producer-consumer scheduler with rate limiting and retry logic for managing concurrent download tasks.

    Pythonapidouyinplugin
    在 GitHub 上查看↗8,673
  • roadrunner-server/roadrunnerroadrunner-server 的头像

    roadrunner-server/roadrunner

    8,473在 GitHub 上查看↗

    RoadRunner is a high-performance application server and process manager designed to serve PHP applications using a persistent worker model. It eliminates bootload overhead and initialization time by keeping application processes alive between requests, acting as a protocol-agnostic proxy that routes traffic to a pool of supervised workers. The server is built with a plugin-based modular architecture, allowing it to be extended with custom Go plugins and compiled into tailored binaries. It distinguishes itself by providing a unified execution model for a wide array of communication protocols,

    Increases throughput by sending multiple tasks to a queue in a single delivery.

    Goapplication-servergolanghacktoberfest
    在 GitHub 上查看↗8,473
  • pandownloadserver/serverPanDownloadServer 的头像

    PanDownloadServer/Server

    8,163在 GitHub 上查看↗

    This project is a remote file transfer server and asynchronous download orchestrator. It functions as a backend service that manages a queue of remote file transfer requests to coordinate the download of files from the web to a remote storage destination. The system operates as a distributed download coordinator, scheduling and tracking the progress of file transfers across different network nodes. It routes data requests from a client to a remote file system and utilizes asynchronous task execution to process heavy file operations in the background. The server includes capabilities for queu

    Organizes background download tasks into managed queues for structured processing pipeline execution.

    HTML
    在 GitHub 上查看↗8,163
  • richardknop/machineryRichardKnop 的头像

    RichardKnop/machinery

    7,956在 GitHub 上查看↗

    Machinery is a distributed task queue and asynchronous workflow engine. It provides a system for processing heavy workloads outside the main request flow using a network of distributed background workers and a message-based job orchestrator. The project manages complex task lifecycles through sequential chaining, where results are passed between tasks, and parallel coordination, which can trigger callback tasks upon the completion of a group. It supports periodic workflow scheduling for recurring jobs and delayed execution via specific timestamps. The system includes capabilities for result

    Supports routing keys to organize background tasks into named queues for managed execution and workload balancing.

    Goamqpaws-sqsgo
    在 GitHub 上查看↗7,956
上一个123下一个
  1. Home
  2. DevOps & Infrastructure
  3. Task Queues

探索子标签

  • Asynchronous Task GroupsMechanisms for tracking the progress of multiple concurrent operations and triggering notifications upon completion. **Distinct from Task Queues:** Distinct from Task Queues: focuses on grouping and monitoring completion of concurrent tasks rather than just queue management.
  • Batch Dispatching1 个子标签Mechanisms for sending multiple tasks to a queue in a single delivery to optimize throughput. **Distinct from Task Queues:** Focuses on the bulk delivery of tasks rather than the logical grouping of queues.
  • Dependency Graph QueuesMaintains an ordered task list where each task can declare prerequisites, forming a directed acyclic graph that controls execution order. **Distinct from Task Queues:** Distinct from Task Queues: adds a dependency graph that controls execution order, not just a simple queue.
  • Django Task Queue Adapters2 个子标签Adapters that allow Django applications to define and execute background tasks using a Huey-based consumer as the execution backend. **Distinct from Task Queues:** Distinct from general Task Queues: focuses specifically on integrating Django's task declaration system with the Huey consumer, not on generic queue management.
  • FIFOTask queues that enforce strict first-in-first-out processing, often through group-key partitioning. **Distinct from FIFO Queues:** Focuses on the architectural enforcement of FIFO order for task processing rather than simple data structure logic.
  • Filesystem-Backed QueuesTask queues that persist tasks as files on disk, using directory watching or periodic scanning to detect and execute new work. **Distinct from Task Queues:** Distinct from general Task Queues: uses the filesystem as the persistence medium rather than Redis, SQLite, or in-memory storage.
  • Image Generation QueuesQueues for managing sequential execution of image generation tasks. **Distinct from Task Queues:** Distinct from general Task Queues: specifically queues image generation requests, not arbitrary background tasks.
  • MongoDB Persistence ProvidersSpecific implementations of task queues that use MongoDB for metadata storage and locking. **Distinct from Task Queues:** Focuses on the MongoDB-specific storage implementation rather than general queue organization.
  • Multi-Backend Implementations1 个子标签Task queues supporting Redis, SQLite, filesystem, and in-memory storage backends for flexibility. **Distinct from Task Queues:** Distinct from Task Queues: emphasizes support for multiple storage backends, not just logical queue grouping.
  • NetworkQueues specifically for organizing the sequential or simultaneous execution of network requests. **Distinct from Task Queues:** Distinct from general task queues by specializing in network upload and download requests.
  • Pluggable OrderingReplaces the default FIFO queue with a custom implementation to control task ordering and execution priority. **Distinct from Task Queues:** Distinct from Task Queues: focuses on the ability to swap the queue implementation itself, not just grouping tasks into named queues.
  • Pluggable Queue Orderings1 个子标签Replaces the default FIFO queue with custom ordering logic for priority or deadline control. **Distinct from Task Queues:** Distinct from generic Task Queues: focuses on replaceable queue ordering, not just task grouping.
  • Queue Capacity Configurators1 个子标签Settings for defining message queue sizes and task priority limits for active components. **Distinct from Task Queues:** Distinct from Task Queues: focuses on the configuration of queue capacity and depth for embedded task management rather than general task grouping.
  • Queue Cleanup OperationsOperations to remove completed or failed tasks from the queue to keep it tidy. **Distinct from Task Queues:** Distinct from Task Queues: focuses on cleanup and maintenance of queue entries rather than queue management or execution.
  • Queue Location ConfigurationConfiguring the physical directory paths used by task queues for logs and locks. **Distinct from Task Queues:** Focuses on the spatial/filesystem configuration of the queue, not its capacity or state management.
  • Queue Pattern MatchingMechanisms to select specific queues for processing using wildcards and negation patterns. **Distinct from Task Queues:** Focuses on the pattern-based selection of queues by workers rather than general task grouping.
  • Queue ReorderingCapabilities for changing the execution order of tasks already in a queue by swapping positions. **Distinct from Task Queues:** Distinct from Task Queues: focuses on reordering queued items rather than grouping or managing the queue itself.
  • Queue Wait Timeouts1 个子标签Cancelling a task if it remains unscheduled in the queue beyond a configurable time limit. **Distinct from Task Queues:** Distinct from Task Queues: focuses on time-based cancellation of queued tasks, not logical grouping or queue management.
  • Reconciliation QueuesQueues designed to decouple event detection from state reconciliation with retry logic. **Distinct from Task Queues:** Focuses on the controller reconciliation pattern rather than general background job processing infrastructure.
  • Standalone ServersQueue implementations that operate as independent server processes rather than embedded libraries. **Distinct from Embedded Queue Servers:** Distinct from embedded servers by running as a separate process that clients connect to over a network.
  • Task ExpirationsMechanisms to prevent a queued task from executing if it remains pending beyond a specified absolute or relative time limit. **Distinct from Task Queues:** Distinct from Task Queues: focuses on time-based expiration of queued items rather than queue organization or routing.