19 Repos
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 ist eine Webanwendung, die darauf ausgelegt ist, Python-Softwarepakete für eine globale Community von Benutzern zu hosten, zu speichern und zu verteilen. Sie fungiert als zentrales Paket-Repository und Index-Server, der Softwareversionen, Metadaten und Paketklassifizierungen verwaltet. Das Projekt implementiert eine sichere Paket-Attestierung durch die Überprüfung der Distributionsintegrität mittels kryptografischer Signaturen und Transparenz-Logs. Es verwaltet die Benutzeridentität über einen OAuth-Provider, der Drittanbieter-Identitätsdienste mittels sicherer Tokens integriert. Das System deckt ein breites Spektrum an Infrastrukturfunktionen ab, einschließlich asynchronem Task-Processing für Hintergrundjobs und E-Mail-Versand, versionierten Datenbank-Schema-Migrationen mit paralleler Indizierung sowie Zugriffskontrolle basierend auf Benutzergruppenmitgliedschaften. Es enthält zudem Tools für die Interface-Lokalisierung und das Tracking von Paketaktivitäten über sequentielle Event-Journale. Entwicklungs-Utilities werden für Request-Simulation, Datenbank-Seeding und die Inspektion des internen Anwendungszustands bereitgestellt.
Employs a background processor to handle long-running tasks and email dispatch without blocking the main thread.
gpu.cpp ist eine leichtgewichtige C++-Bibliothek zur Ausführung von Low-Level-General-Purpose-GPU-Berechnungen über verschiedene Hardwareanbieter und Betriebssysteme hinweg. Sie fungiert als portabler GPU-Wrapper, Kernel-Orchestrator und Tensor-Managementsystem unter Verwendung der WebGPU-Spezifikation, um Geräteinitialisierung, Pufferübertragungen und Compute-Shader-Dispatching zu abstrahieren. Die Bibliothek bietet ein Framework zur Definition von Compute-Kerneln aus Shader-Code und zur Verwaltung ihrer asynchronen Ausführung und Synchronisation. Sie ermöglicht die Ausführung plattformübergreifender Compute-Shader und die Orchestrierung von GPU-Aufgaben durch eine standardisierte Grafikprozessor-Spezifikation. Das System handhabt den gesamten Lebenszyklus von GPU-Speicher, einschließlich der Allokation mehrdimensionaler Tensoren, bidirektionaler Datenbewegung zwischen Host und Gerät über Staging-Puffer sowie Ressourcen-Tracking zur Vermeidung von Speicherlecks. Es unterstützt zudem Tensor-Slicing zur Erstellung nicht-besitzender Views von Speichersegmenten und enthält Dienstprogramme für System-Message-Logging und Schweregrad-Filterung.
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 ist eine Ruby-Bibliothek, die ein datenbankgestütztes System für die asynchrone Aufgabenverarbeitung bereitstellt. Sie ermöglicht das Auslagern langlaufender oder zeitaufwendiger Operationen an Hintergrund-Worker durch die Serialisierung von Methodenaufrufen und deren Argumenten in einer relationalen Datenbank, wodurch sichergestellt wird, dass Aufgaben auch nach Anwendungsneustarts bestehen bleiben. Das System fungiert als verteilter Prioritäts-Task-Scheduler, bei dem unabhängige Worker-Prozesse kontinuierlich die Datenbank auf anstehende Jobs abfragen. Durch die Integration der Task-Erstellung direkt in die Datenbanktransaktionen der Anwendung wird garantiert, dass Jobs nur dann in die Warteschlange eingereiht werden, wenn die zugehörige Geschäftslogik erfolgreich ist. Diese Architektur ermöglicht horizontales Skalieren durch den Betrieb mehrerer gleichzeitiger Worker-Prozesse auf verschiedenen Maschinen, um hohe Aufgabenvolumina zu bewältigen. Über die reine Ausführung hinaus unterstützt die Bibliothek verzögertes Scheduling und Aufgabenpriorisierung, sodass kritische Operationen vor Hintergrundarbeiten mit niedrigerer Priorität verarbeitet werden können. Sie enthält zudem administrative Werkzeuge für die Wartung der Warteschlangen und bietet die Möglichkeit, anstehende Aufgaben zu löschen, zurückzusetzen oder zu entfernen, um den Status des Hintergrundverarbeitungssystems zu verwalten.
Executes deferred operations in Ruby applications by polling a database table for pending jobs and processing them sequentially.