11 Repos
Systems for managing long-running background jobs through request queueing and status polling.
Distinct from Image Request Queues: Covers general asynchronous task management for AI generation rather than specific priority-based image load requests.
Explore 11 awesome GitHub repositories matching software engineering & architecture · Asynchronous Task Queues. Refine with filters or upvote what's useful.
StableStudio is a generative AI frontend and image interface designed for creating and editing visual content. It provides a web-based graphical interface that connects to generative AI models via API connections to facilitate image synthesis and modification. The project functions as a pluggable AI backend manager, using a modular system to standardize diverse AI provider APIs into a unified format. This architecture allows users to swap between different generative AI backends and providers to compare outputs and optimize production. The system manages long-running generation tasks through
Manages long-running image generation tasks via an asynchronous queue and completion polling.
This project is a PHP implementation of the Promises/A+ specification, providing a library for managing asynchronous operations and deferred values. It serves as an asynchronous task coordinator that allows for the creation of non-blocking code through a promise-based pattern. The library enables the simulation of asynchronous coroutines, allowing non-blocking code to be written in a linear style. It features duck-typed interoperability, which allows it to integrate with any foreign object that implements a then method regardless of class inheritance. The project covers broader capabilities
Utilizes a global queue to process pending promise handlers, maintaining a constant stack size during execution.
es6-promise is an ES6 promise polyfill and JavaScript compatibility layer. It provides a standardized interface for managing asynchronous flow control and background tasks in environments that lack native support for the ES6 Promise specification. The project serves as a bridge to ensure consistent asynchronous behavior across different browser engines and legacy environments. It includes utilities for global promise injection and polyfilling, which add the implementation to the global namespace for application-wide availability. The library covers the coordination of asynchronous workflows,
Utilizes internal handler execution queues to manage and sequence the execution of success and failure callbacks.
Hakuneko ist ein plattformübergreifender Manga-Downloader und Media-Scraper, der entwickelt wurde, um Manga- und Anime-Bilder sowie Videos von verschiedenen Webseiten zu speichern. Er fungiert als Tool für den Offline-Medienkonsum und ermöglicht es Benutzern, visuelle Inhalte von Webquellen zu extrahieren und lokal zu speichern. Die Anwendung ermöglicht plattformübergreifende Medienarchivierung unter Windows, Linux und macOS. Sie konzentriert sich auf das Scrapen von Webinhalten, um lokale Archive von Bildern und Videos zu erstellen und sicherzustellen, dass Inhalte auch ohne Internetverbindung zugänglich bleiben. Das System verwaltet diese Aufgaben durch eine Connector-Architektur und Headless-Browser-Automatisierung unter Verwendung von asynchroner Queue-Verarbeitung und User-Agent-Rotation. Es organisiert heruntergeladene Medien mittels lokaler Dateisystem-Mappings, um eine strukturierte Verzeichnishierarchie basierend auf Metadaten beizubehalten.
Implements asynchronous task queues to manage concurrent download requests and prevent network congestion.
Director is a routing library for JavaScript that handles URL and command-line pattern matching across client-side, server-side, and CLI environments. It provides a unified approach to defining routes as nested object literals, where each key maps to a URL segment and its handler, supporting both hash fragment monitoring and the HTML5 History API for browser navigation without page reloads. The library distinguishes itself through its ability to operate in multiple contexts with a single routing paradigm. It supports asynchronous handler queue execution for sequential tasks like authenticatio
Provides a queue-based mechanism for executing route handlers sequentially with async control flow.
Forge ist eine JavaScript-Kryptografie-Bibliothek, die einen umfassenden Satz an Tools für symmetrische und asymmetrische Verschlüsselung, Hashing und digitale Signaturen bereitstellt. Sie enthält eine vollständige Implementierung von Transport Layer Security (TLS) zum Aufbau sicherer Netzwerkverbindungen und zur Verwaltung verschlüsselten Traffics. Das Projekt implementiert eine Vielzahl von Public-Key-Infrastruktur-Tools, einschließlich X.509-Zertifikatsverwaltung, Generierung von Certificate Signing Requests (CSR) und Validierung von Zertifikatsketten. Es bietet ein PKCS-Kryptografie-Toolkit für den Umgang mit sicheren Archiven und signierten Nachrichten sowie Unterstützung für SSH-Key-Management und die Konvertierung von Schlüsseln zwischen PEM-, OpenSSH- und PKCS#12-Formaten. Die Bibliothek deckt ein breites Spektrum an Sicherheitsprimitiven ab, wie Blockchiffre-Verschlüsselung, HMAC-Berechnung und passwortbasierte Schlüsselableitung. Sie enthält zudem Utilities für die Serialisierung binärer Daten mittels ASN.1 DER-Kodierung sowie Datentransformationstools für Base58, Base64 und hexadezimale Formate. Zusätzliche Funktionen umfassen Low-Level-Netzwerkkommunikations-Utilities für die Handhabung von HTTP-Client-Requests und asynchrone Aufgabenorchestrierung für das Queuing von Hintergrundoperationen.
Implements a task queue for coordinating the execution order of asynchronous background operations.
Dieses Projekt ist eine Multi-Engine-Media-Downloader- und Web-Media-Scraper-Schnittstelle. Als native Qt-C++-Desktopanwendung gebaut, dient sie als grafisches Frontend zur Orchestrierung mehrerer Backend-Downloader wie yt-dlp, gallery-dl und aria2c, um Video-, Audio- und Bildinhalte aus dem Web zu erfassen. Die Software unterscheidet sich durch ein Routing-System, das RegEx-basiertes Engine-Mapping verwendet, um spezifische Backend-Tools URLs basierend auf ihrer Domain zuzuweisen. Sie enthält ein Abonnement-Management-System, das Remote-Playlists überwacht, um neue Medieneinträge automatisch zu identifizieren und in die Warteschlange einzureihen, sobald sie veröffentlicht werden. Die breiten Funktionen decken Batch-Image-Scraping, den Abruf großer Dateien und das Herunterladen von Medien-Playlists ab. Die Schnittstelle ermöglicht die Konfiguration von Download-Presets, globalen Engine-Defaults und den Import von Browser-Session-Cookies, um auf eingeschränkte Inhalte zuzugreifen. Die Anwendung verwendet JSON-basierte Konfigurationsdateien, um Nutzereinstellungen, Engine-Konfigurationen und visuelle Interface-Themes beizubehalten.
Implements an asynchronous task queue to manage background downloads without blocking the user interface.
IPProxyPool ist ein HTTP-Proxy-Pool-Manager, der eine rotierende Liste funktionaler Proxy-Adressen crawlt, validiert und über eine programmatische API bereitstellt. Er integriert Proxy-Scraping, Konnektivitätsvalidierung und persistente Datenbankspeicherung, um eine verwaltete Quelle von IP-Adressen für Netzwerkanfragen bereitzustellen. Das System verwendet eine plugin-basierte Scraping-Architektur, um IP-Adressen von mehreren externen Websites zu sammeln, sowie eine asynchrone Validierungswarteschlange, um diese Kandidaten parallel zu testen. Es differenziert seinen Pool durch die Zuweisung numerischer Stabilitäts-Scores an Proxys mittels periodischer Health-Checks und Konnektivitätsverifizierung, was den Abruf hochstabiler Adressen ermöglicht, die nach Region und Protokoll gefiltert sind. Das Projekt enthält eine Datenbank-Abstraktionsschicht mit anschließbaren Backends für die Datenpersistenz und bietet Tools zum Löschen spezifischer Proxy-Einträge. Es unterstützt zudem benutzerdefinierte Validierungslogik, um die spezifischen Kriterien zur Bestimmung der Proxy-Gültigkeit zu definieren.
Implements a system for managing long-running proxy validation jobs through an asynchronous task queue.
RxAndroidBle is a reactive framework designed to simplify Bluetooth Low Energy interactions on Android. It functions as a wrapper for the system Bluetooth stack, converting low-level asynchronous callbacks into observable streams to manage device discovery, connection lifecycles, and data communication. The library distinguishes itself by normalizing inconsistent vendor-specific Bluetooth behaviors into a predictable interface, ensuring reliable cross-device compatibility. It incorporates an internal operation queueing mechanism that serializes concurrent hardware requests, preventing command
Serializes concurrent GATT requests into a managed pipeline to prevent command collisions and ensure stable communication.
This library is a framework for Android applications to manage Bluetooth Low Energy connectivity, peripheral discovery, and data exchange. It provides a standardized interface for integrating wireless hardware, enabling developers to handle complex communication tasks through a structured connectivity framework. The library distinguishes itself by implementing a managed operation pipeline that serializes asynchronous commands to prevent hardware collisions. It utilizes a state-machine-based approach to track connection lifecycles, which automates retry logic and maintains stable links across
Serializes asynchronous GATT requests into a managed pipeline to prevent hardware command collisions.
Diese Bibliothek bietet ein Entwicklungs-Framework für die Verwaltung von Bluetooth Low Energy-Verbindungen und den Datenaustausch auf Android-Geräten. Sie fungiert sowohl als Client-Manager für die Ausführung von Lese- und Schreiboperationen mit Hardware-Peripheriegeräten als auch als Server-Framework für die Konfiguration lokaler Geräte zum Hosten von GATT-Diensten. Die Bibliothek zeichnet sich durch eine verwaltete, warteschlangenbasierte Architektur aus, die asynchrone Anfragen serialisiert, um Befehlskollisionen zu verhindern und eine zuverlässige Übertragung sicherzustellen. Sie automatisiert komplexe Aufgaben wie Paket-Splitting, Service-Discovery und Verbindungs-Wiederholungsversuche, während sie persistente Verbindungen über Anwendungslebenszyklus-Übergänge hinweg aufrechterhält. Über die grundlegende Konnektivität hinaus enthält das Framework Tools zur Leistungsoptimierung und Echtzeit-Zustandssynchronisation. Es macht Hardware-Verbindungsereignisse und Datenaktualisierungen über reaktive Streams zugänglich, wodurch Anwendungen Statusänderungen überwachen und Schnittstellenaktualisierungen automatisch auslösen können. Die Bibliothek wird als Android-spezifisches Entwicklungspaket vertrieben.
Ensures reliable data transmission by serializing asynchronous Bluetooth requests into a managed pipeline.