19 个仓库
Systems designed to handle background operations, file processing, and long-running tasks without blocking the main application thread.
Distinguishing note: Specifically targets the architectural pattern of non-blocking task execution for data-heavy pipelines.
Explore 19 awesome GitHub repositories matching software engineering & architecture · Asynchronous Task Processors. Refine with filters or upvote what's useful.
Quivr is a retrieval-augmented generation platform designed to transform raw documents into searchable knowledge bases. It functions as a centralized environment where users can ingest files, index them into vector databases, and interact with language models to receive contextually relevant, data-backed responses. The platform distinguishes itself through an agentic workflow orchestrator that sequences retrieval tasks, tool execution, and model interactions to resolve complex, multi-step queries. This engine is entirely configuration-driven, allowing users to define document ingestion, chunk
Processes file uploads, indexing, and retrieval operations using non-blocking methods to maintain system responsiveness during heavy data ingestion.
This project is a Kubernetes serverless framework and OCI container function platform. It provides a system for deploying event-driven functions and microservices as compatible container images onto a Kubernetes cluster. The platform includes an event-driven function orchestrator that triggers executions via HTTP requests or message streams. It features an auto-scaling function manager that adjusts the number of active instances based on real-time demand and scales down to zero during inactivity. A background queuing system is included to process asynchronous tasks and maintain application re
Provides a background queuing system to handle long-running tasks without blocking the main application.
Dapper is a lightweight object-relational mapper for .NET that functions as a high-performance data access library. It operates by extending standard database connection interfaces, allowing developers to execute raw SQL queries while automating the mapping of database results to strongly-typed objects. The library distinguishes itself through its use of runtime code generation, which creates high-performance instructions to map database rows to object properties with minimal overhead. It provides flexible data retrieval options, supporting both memory-buffered loading for speed and row-by-ro
Implements non-blocking task patterns to ensure database operations remain responsive during high-latency I/O.
The Rust Programming Language Book is the official technical guide and educational resource for the Rust language. It provides a comprehensive walkthrough of the language's design, focusing on its core identity as a systems programming language that enforces memory safety and high-performance execution without the need for a garbage collector. The project is distinguished by its focus on ownership, borrowing, and lifetime tracking, which allow the compiler to verify memory safety and thread safety at compile time. It covers the language's unique approach to zero-cost abstractions, including t
Defines units of work that resolve to values when polled by an asynchronous runtime.
NodeBB is a real-time, self-hosted community forum platform built on Node.js. It is designed to support scalable discussion environments by utilizing a document-oriented database for content storage and an in-memory engine for high-speed data retrieval and session management. The platform provides a comprehensive administrative interface for managing user groups, forum settings, and system health. What distinguishes the platform is its native support for federated social networking via the ActivityPub protocol, allowing forums to exchange content, synchronize discussions, and interact with de
Executes custom logic in the background after specific events to maintain responsiveness without blocking the main application flow.
Workflow is an asynchronous C++ task engine designed for building distributed systems and high-performance network services. It provides a framework for orchestrating complex sequences of network, file, and computational operations, allowing developers to compose these tasks into parallel workflows. The library functions as a toolkit for implementing scalable servers and clients for protocols such as HTTP, Redis, MySQL, and Kafka. It distinguishes itself through a task-based concurrency model that manages non-blocking operations and coordinates service discovery, load balancing, and traffic r
Executes complex sequences of network, file, and computational operations using a task-based model to maximize system throughput.
This project is an orchestration framework designed to automate creative and research workflows by managing specialized artificial intelligence agents. It functions as a content generation system that delegates complex, multi-step tasks to model instances, ensuring that each agent operates within defined behavioral constraints and design methodologies. The framework distinguishes itself through its focus on structural integrity and brand consistency. It employs schema-driven validation to ensure that all generated content adheres to predefined templates and data formats. By utilizing custom s
Offloads resource-intensive model inference to background workers to maintain application responsiveness.
Chainlit is a Python framework designed for building and deploying interactive, stateful conversational AI interfaces. It provides a backend-driven platform that connects language models and agent frameworks to a web-based chat frontend, managing the complexities of session state, message history, and real-time communication. The framework distinguishes itself by offering a component-based UI builder that allows developers to inject interactive widgets, rich media, and data visualizations directly into the chat stream. It supports the visualization of complex agent workflows, enabling users t
Offloads long-running operations to background threads to maintain responsiveness during model inference.
PocketFlow is a graph-based framework for designing and executing large language model operations and reasoning patterns. It serves as an orchestrator for building goal-oriented autonomous agents, multi-agent systems, and retrieval-augmented generation pipelines. The system is distinguished by its ability to coordinate autonomous AI agents that use shared memory and tools to solve complex goals, supported by a structured output engine that enforces schema-consistent responses. It utilizes graph-based workflow orchestration to manage sequences of model operations and supports supervisor-based
Executes non-blocking model calls and external API operations to maintain system responsiveness.
Seastar is a C++ server application framework and asynchronous programming library designed for building high-performance, shared-nothing server applications. It functions as a high-performance I/O engine providing direct disk and network access through a shared-nothing framework that partitions data and execution across CPU cores. The framework distinguishes itself through a thread-per-core architecture that eliminates locking and resource contention by assigning one execution thread to each physical CPU core. It implements a userspace TCP/IP stack and kernel-bypass techniques, integrating w
Implements non-blocking server logic using futures and coroutines to manage high-concurrency tasks.
Nunjucks is a JavaScript templating engine used for generating dynamic HTML by combining data with templates. It serves as an asynchronous template processor that allows for non-blocking execution within filters and parallel processing of iterations. The engine features a template inheritance system where base skeleton structures are defined and extended by child templates to fill specific content blocks. It includes a security utility for context-aware HTML escaping to prevent cross-site scripting during the rendering phase. The library provides capabilities for server-side rendering and da
Processes templates asynchronously, allowing for non-blocking calls within filters and parallel iteration.
GoCV is a computer vision library and Go language binding for OpenCV. It serves as an image processing toolkit and deep learning inference engine, providing programmatic access to a wide range of algorithms for image manipulation, object detection, and video analysis. The project differentiates itself through high-performance native bindings and hardware acceleration. It utilizes a foreign function interface to map Go calls to C++ functions and includes a hardware-agnostic backend dispatch to route neural network tasks to computation engines such as CUDA and OpenVINO. The library covers a br
Executes CUDA operations asynchronously to allow multiple tasks to run without blocking the main thread.
STranslate is a desktop translation application that integrates optical character recognition with translation services. It functions as a screen OCR tool designed to capture digital text from images or the display to make the content editable and convertible between languages. The software provides a real-time workflow for screen text translation, allowing the conversion of foreign language text from software or documents into a native language without manual copying and pasting. The system manages the end-to-end process from screen-capture buffer processing and text recognition to asynchro
Implements background task processing to ensure the UI remains responsive during OCR and translation requests.
Shiny is a framework for building interactive web applications using R code, eliminating the need for HTML, CSS, or JavaScript. At its core, it provides a reactive programming model that automatically tracks data dependencies and re-executes only the parts of an application that depend on changed inputs. The framework handles server-side UI rendering and maintains persistent WebSocket connections between the browser and server for real-time updates without page reloads. The framework distinguishes itself through deep integration with the R ecosystem, including the ability to embed interactive
Executes long-running operations in the background without blocking the main application from responding to users.
Warehouse 是一个 Web 应用,旨在为全球用户社区托管、存储和分发 Python 软件包。它作为一个中央包仓库和索引服务器,管理软件版本、元数据和包分类。 该项目通过加密签名和透明度日志验证分发完整性,实现安全包证明。它通过 OAuth 提供商管理用户身份,该提供商使用安全令牌与第三方身份服务集成。 该系统涵盖了广泛的基础设施功能,包括用于后台作业和电子邮件分发的异步任务处理、具有并发索引的版本化数据库模式迁移,以及基于用户组成员资格的访问控制。它还包括用于界面本地化和通过顺序事件日志跟踪包活动的工具。 开发工具提供用于请求模拟、数据库播种和内部应用状态检查。
Employs a background processor to handle long-running tasks and email dispatch without blocking the main thread.
gpu.cpp 是一个轻量级的 C++ 库,用于跨不同硬件供应商和操作系统执行底层通用 GPU 计算。它作为一个便携式 GPU 包装器、内核编排器和张量管理系统,利用 WebGPU 规范来抽象设备初始化、缓冲区传输和计算着色器调度。 该库提供了一个框架,用于从着色器代码定义计算内核,并管理其异步调度与同步。它支持跨平台计算着色器的执行,并通过标准化的图形处理器规范编排 GPU 任务。 该系统处理 GPU 内存的全生命周期,包括多维张量的分配、通过暂存缓冲区在主机与设备之间的双向数据移动,以及防止内存泄漏的资源跟踪。它还支持用于创建非所有权内存段视图的张量切片,并包含系统消息日志记录和严重性过滤工具。
Coordinates the dispatch of GPU kernels using asynchronous primitives to manage non-blocking execution.
Once Campfire is a self-hosted team chat platform and real-time messaging server. It provides a web-based communication environment for internal team messaging, featuring group channels, private direct messages, and a bot-integrated system for automating external messaging services. The platform is distributed as a dockerized collaboration suite, allowing for containerized deployment with bundled application dependencies and automated SSL provisioning. The system covers a broad range of collaboration capabilities, including chat management with granular access controls, file attachment shari
Ships an asynchronous task processor for handling background operations and long-running scripts.
AI-Video-Transcriber is an automated media processing platform that converts audio and video files into structured, searchable text documents. It utilizes speech-to-text recognition and external language models to perform transcription, summarization, and translation of media content. The system distinguishes itself through a modular pipeline that orchestrates media extraction, processing, and storage. It features automated media monitoring that tracks channels to compile periodic content digests, alongside a vector-based knowledge retrieval engine that allows users to query their stored tran
Implements non-blocking background processing for media extraction and transcription tasks.
Delayed Job 是一个 Ruby 库,提供了一个基于数据库的异步任务处理系统。它通过将方法调用及其参数序列化到关系数据库中,将长时间运行或耗时的操作卸载到后台工作进程,确保任务在应用重启后依然存在。 该系统作为分布式优先级任务调度器运行,独立的 Worker 进程持续轮询数据库以获取待处理作业。通过将任务创建直接集成到应用数据库事务中,它保证了仅在相关业务逻辑成功时才对作业进行排队。这种架构允许通过在不同机器上运行多个并发 Worker 进程来水平扩展,以处理大量任务。 除了基本执行外,该库还支持延迟调度和任务优先级排序,允许在低优先级后台工作之前处理关键操作。它还包括用于队列维护的管理工具,提供清除、重置或移除待处理任务的能力,以管理后台处理系统的状态。
Executes deferred operations in Ruby applications by polling a database table for pending jobs and processing them sequentially.