14 个仓库
Systems for managing and distributing asynchronous background jobs.
Distinguishing note: Focuses on architectural task distribution rather than specific data processing.
Explore 14 awesome GitHub repositories matching software engineering & architecture · Task Queues. Refine with filters or upvote what's useful.
React 是一个用于构建用户界面的 JavaScript 库,采用组件化架构和单向数据流。
Allows rendering work to be paused, resumed, or aborted to keep the interface responsive during heavy tasks.
Umi-OCR is an optical character recognition engine designed to convert visual text from images and documents into machine-readable character data. It functions as a local-first toolkit, processing all visual data directly on the host machine using embedded neural network models to maintain privacy and offline availability. The project distinguishes itself through its focus on automated document digitization and integrated barcode and QR code decoding. By utilizing a modular, Python-based orchestration layer, it enables users to transform static image files and multi-page documents into search
Distributes document and image analysis jobs across a non-blocking execution pipeline for improved throughput.
Marker is a comprehensive document processing platform designed to automate the conversion, extraction, and structuring of data from complex files. It functions as an orchestration engine that chains modular processing steps into versioned, reusable pipelines, allowing organizations to standardize document handling and automate repetitive business tasks at scale. The platform distinguishes itself through its support for secure, private infrastructure deployment, enabling users to run containerized services within their own environments to maintain strict data privacy. It features specialized
Processes long-running document conversion and extraction jobs in the background to maintain high throughput.
Celery is an asynchronous job processor and distributed task queue designed to offload time-consuming operations to background worker nodes. By utilizing a message-passing architecture, it decouples task producers from consumers, allowing applications to maintain responsiveness while scaling workloads across multiple isolated environments. The system functions as a distributed workload orchestrator that manages the lifecycle of deferred operations through persistent queues. It distinguishes itself by providing a pluggable transport abstraction, which allows the core task logic to remain indep
A message-passing architecture that offloads time-consuming operations to background worker nodes to maintain responsive application performance.
NSQ is a distributed, brokerless messaging platform designed for high-throughput, fault-tolerant communication. By utilizing a decentralized topology, it eliminates single points of failure and allows for horizontal scaling across clusters. The system organizes message streams into topics and channels, effectively decoupling producers from consumers to support both streaming and job-oriented workloads. The platform distinguishes itself through a lookup-service-based discovery mechanism that enables clients to dynamically locate producers at runtime without requiring centralized coordination.
Handles background jobs and event-driven workflows with reliable at-least-once delivery guarantees.
Pyvideotrans is an automated video localization platform designed to transcribe, translate, and dub media content for international distribution. It functions as an end-to-end workflow that combines speech recognition, text translation, and synthetic voice generation to process video files into localized versions. The system distinguishes itself by offering a choice between local model inference for privacy and integration with third-party cloud services via user-provided credentials. This architecture allows users to maintain control over their billing and data security while utilizing modul
Manages sequential execution of multiple media jobs through a command-line interface for large-scale processing.
Taskflow is a C++ task-parallel framework designed to build high-performance parallel workflows and complex dependency graphs. It provides a programming model that organizes computational work into directed acyclic graphs, enabling developers to manage concurrency, resource scheduling, and task dependencies across multi-core CPUs and GPU accelerators. The framework distinguishes itself through its ability to orchestrate heterogeneous systems, allowing for the integration of hardware-accelerated kernels and memory operations into unified execution pipelines. It supports dynamic runtime subflow
Allocates work-stealing queues to store and distribute parallel tasks across multiple threads for efficient load balancing.
HVM2 is a high-performance execution environment for pure functional programs, implemented as a systems-level runtime in Rust. It functions as a massively parallel functional runtime that uses interaction combinators to achieve automatic parallelism across multi-core CPUs and GPUs. The project distinguishes itself by using a graph-rewriting computational model to execute programs via local reduction rules, which eliminates the need for manual locks or atomic operations. It employs beta-optimal reduction and lazy evaluation to optimize higher-order functions and eliminate redundant computation
Distributes the computation of expressions across a pool of threads using a work-stealing queue to maximize hardware utilization.
Crossbeam is a concurrency toolkit for Rust providing low-level primitives for writing multi-threaded programs. It focuses on lock-free data structures and memory management primitives designed for shared-memory concurrent environments. The project includes a work-stealing scheduler that uses double-ended queues to balance workloads across multiple processor cores. This system enables the implementation of work-stealing deques to distribute tasks and prevent bottlenecks. The toolkit covers broader capabilities for parallel algorithm development, multi-threaded task scheduling, and general co
Provides work-stealing deques that allow idle threads to steal tasks from busy workers.
Fastdom is a task scheduler and rendering optimizer designed to prevent layout thrashing by batching document reads and writes. It functions as a coordination system that separates document measurements and mutations into distinct queues, ensuring that asynchronous operations are executed in a way that minimizes browser reflows. The project provides a performance profiling capability that detects improper document API access. By enforcing strict execution phases, it identifies layout thrashing bottlenecks and flags unauthorized DOM access occurring outside of the coordinated batching cycles.
Maintains a centralized architectural task queue to process pending operations sequentially during animation frames.
Hazelcast is a distributed data platform that combines an in-memory data grid with a stream processing engine to support real-time analytics and event-driven applications. It functions as a partitioned, distributed key-value store that replicates data across cluster nodes to provide low-latency access and high availability. The platform also serves as a distributed SQL query engine, allowing users to execute standard SQL statements against both in-memory datasets and external data sources. What distinguishes Hazelcast is its use of a distributed consensus subsystem to maintain strongly consis
Implements a first-in-first-out queue that allows cluster members and clients to enqueue and dequeue serializable objects across a network.
async-std 是一个 Rust 异步运行时和非阻塞 I/O 库。它作为一个异步标准库,提供了一组核心 Rust 库的替代方案,用于管理并发任务、网络和文件系统访问。 该项目实现了与标准库镜像的 API,提供现有同步类型的异步版本以保持熟悉的接口。这种方法允许使用反映语言标准库人体工程学的接口进行异步 Rust 开发。 该运行时包括一个用于跨多个线程调度和执行异步操作的任务执行器。其功能表面涵盖并发任务执行、非阻塞输入和输出操作以及常规运行时管理。
Uses a work-stealing queue strategy to balance computational load across worker threads.
RavenDB is a multi-model NoSQL document database designed for high-performance, ACID-compliant data storage. It persists structured information as schema-flexible JSON documents and utilizes a unit-of-work session pattern to track entity changes and batch modifications into atomic transactions. The platform is built on a distributed architecture that supports horizontal scaling through sharding and ensures high availability via multi-node, master-to-master cluster replication. The database distinguishes itself through a self-optimizing query engine that automatically creates and maintains ind
Assigns background operational tasks to available nodes and automatically reassigns them if a node becomes unavailable.
This repository serves as a tutorial and sample collection for designing cloud-native distributed systems, featuring deployment configurations and sample code focused on recurring microservice patterns. It functions as an architectural pattern guide for building distributed applications on container platforms. The collection demonstrates standard patterns through container configurations and application manifests, covering multi-container pod designs and container interactions. It details infrastructure and orchestration approaches such as running auxiliary containers alongside primary applic
Scales asynchronous workloads using shared message queues where independent worker containers pull processing tasks.