19 dépôts
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 is a web application designed for hosting, storing, and distributing Python software packages to a global community of users. It functions as a centralized package repository and index server that manages software versions, metadata, and package classification. The project implements secure package attestation by verifying distribution integrity through cryptographic signatures and transparency logs. It manages user identity via an OAuth provider that integrates with third-party identity services using secure tokens. The system covers a broad range of infrastructure capabilities, i
Employs a background processor to handle long-running tasks and email dispatch without blocking the main thread.
gpu.cpp is a lightweight C++ library for executing low-level general-purpose GPU computation across different hardware vendors and operating systems. It functions as a portable GPU wrapper, kernel orchestrator, and tensor management system using the WebGPU specification to abstract device initialization, buffer transfers, and compute shader dispatching. The library provides a framework for defining compute kernels from shader code and managing their asynchronous dispatch and synchronization. It enables the execution of cross-platform compute shaders and the orchestration of GPU tasks through
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 est une bibliothèque Ruby qui fournit un système basé sur base de données pour le traitement asynchrone des tâches. Il permet de décharger les opérations de longue durée ou chronophages vers des travailleurs en arrière-plan en sérialisant les appels de méthode et leurs arguments dans une base de données relationnelle, garantissant que les tâches persistent après les redémarrages de l'application. Le système fonctionne comme un planificateur de tâches prioritaire distribué, où des processus de travail indépendants interrogent continuellement la base de données pour les tâches en attente. En intégrant la création de tâches directement dans les transactions de base de données de l'application, il garantit que les tâches ne sont mises en file d'attente que lorsque la logique métier associée réussit. Cette architecture permet une mise à l'échelle horizontale en exécutant plusieurs processus de travail simultanés sur différentes machines pour gérer des volumes élevés de tâches. Au-delà de l'exécution de base, la bibliothèque prend en charge la planification différée et la priorisation des tâches, permettant aux opérations critiques d'être traitées avant le travail en arrière-plan de moindre priorité. Elle inclut également des outils administratifs pour la maintenance des files d'attente, offrant la possibilité d'effacer, de réinitialiser ou de supprimer les tâches en attente pour gérer l'état du système de traitement en arrière-plan.
Executes deferred operations in Ruby applications by polling a database table for pending jobs and processing them sequentially.