19 repository-uri
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 este o aplicație web concepută pentru găzduirea, stocarea și distribuirea pachetelor software Python către o comunitate globală de utilizatori. Funcționează ca un depozit central de pachete și server de index care gestionează versiunile software, metadatele și clasificarea pachetelor. Proiectul implementează atestarea securizată a pachetelor prin verificarea integrității distribuției prin semnături criptografice și jurnale de transparență. Gestionează identitatea utilizatorului printr-un furnizor OAuth care se integrează cu servicii de identitate terțe folosind token-uri securizate. Sistemul acoperă o gamă largă de capabilități de infrastructură, inclusiv procesarea asincronă a sarcinilor pentru joburi de fundal și trimiterea de e-mailuri, migrări de schemă de bază de date versiionate cu indexare concurentă și controlul accesului bazat pe apartenența la grupuri de utilizatori. Include, de asemenea, instrumente pentru localizarea interfeței și urmărirea activității pachetelor prin jurnale de evenimente secvențiale. Utilitarele de dezvoltare sunt furnizate pentru simularea cererilor, popularea bazei de date și inspectarea stării interne a aplicației.
Employs a background processor to handle long-running tasks and email dispatch without blocking the main thread.
gpu.cpp este o bibliotecă C++ ușoară pentru executarea calculului GPU general-purpose de nivel scăzut pe diferite furnizori de hardware și sisteme de operare. Acesta funcționează ca un wrapper GPU portabil, orchestrator de kernel și sistem de gestionare a tensorilor folosind specificația WebGPU pentru a abstractiza inițializarea dispozitivului, transferurile de buffer și dispatching-ul compute shader-elor. Biblioteca oferă un framework pentru definirea compute kernel-urilor din codul shader și gestionarea dispatch-ului și sincronizării lor asincrone. Permite executarea compute shader-elor multi-platformă și orchestrarea sarcinilor GPU printr-o specificație standardizată a procesorului grafic. Sistemul gestionează întregul ciclu de viață al memoriei GPU, incluzând alocarea tensorilor multidimensionali, mișcarea bidirecțională a datelor între gazdă și dispozitiv prin staging buffers și urmărirea resurselor pentru a preveni scurgerile de memorie. De asemenea, suportă slicing-ul tensorilor pentru crearea de vizualizări non-owning ale segmentelor de memorie și include utilitare pentru logarea mesajelor de sistem și filtrarea severității.
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 este o bibliotecă Ruby care oferă un sistem bazat pe baze de date pentru procesarea asincronă a sarcinilor. Permite descărcarea operațiunilor de lungă durată sau consumatoare de timp către worker-i de fundal prin serializarea apelurilor de metode și a argumentelor acestora într-o bază de date relațională, asigurându-se că sarcinile persistă după restartarea aplicației. Sistemul funcționează ca un programator de sarcini distribuit cu priorități, unde procesele worker independente interoghează continuu baza de date pentru sarcini în așteptare. Prin integrarea creării sarcinilor direct în tranzacțiile bazei de date a aplicației, garantează că sarcinile sunt puse în coadă doar atunci când logica de business asociată reușește. Această arhitectură permite scalarea orizontală prin rularea mai multor procese worker concurente pe diferite mașini pentru a gestiona volume mari de sarcini. Dincolo de execuția de bază, biblioteca suportă programarea amânată și prioritizarea sarcinilor, permițând operațiunilor critice să fie procesate înaintea sarcinilor de fundal cu prioritate mai mică. Include, de asemenea, instrumente administrative pentru întreținerea cozii, oferind posibilitatea de a șterge, reseta sau elimina sarcinile în așteptare pentru a gestiona starea sistemului de procesare în fundal.
Executes deferred operations in Ruby applications by polling a database table for pending jobs and processing them sequentially.