25 个仓库
Frameworks and patterns for managing concurrent background processes and non-blocking event loops.
Distinguishing note: Focuses on the architectural pattern of non-blocking task management rather than specific language runtimes.
Explore 25 awesome GitHub repositories matching software engineering & architecture · Asynchronous Task Orchestrators. Refine with filters or upvote what's useful.
Developer Roadmap 是一个社区驱动的平台,提供结构化的、基于图谱的软件工程学习路径。它作为一个综合知识仓库,将技术领域组织成可视化序列,以指导专业技能获取和职业成长。 该项目通过协作生态系统脱颖而出,使用户能够贡献路线图、策划行业最佳实践并维护个人职业档案。它集成了诊断评估框架来评估技术熟练度,帮助开发者识别知识缺口,并通过有针对性的学习序列为专业面试做准备。 除了核心映射能力外,该平台还提供实用的项目创意和交互式辅导,以巩固工程概念。它为社区提供了一个共享资源、跟踪技能进步和导航复杂技术领域的中心化空间。
Decouples system processes using message-driven patterns to handle background tasks and inter-service communication.
Langflow is a low-code platform for designing and deploying multi-step AI agent pipelines and large language model sequences. It provides a visual environment to map logic and data flow between components, serving as an orchestrator for managing conversations and data retrieval across multiple autonomous agents. The platform distinguishes itself through a drag-and-drop interface that allows for the construction of complex AI pipelines without extensive boilerplate code. It enables the conversion of these internal workflows into standardized tools for external connectivity via the Model Contex
Utilizes a non-blocking runtime to manage the execution of multiple agents and tools through sequential and parallel tasks.
This project is a framework for building interactive, graphical-style terminal applications. It provides a declarative component model that organizes user interfaces into a tree of nested widgets, each managing its own lifecycle, state, and rendering. By subclassing the base application class, developers can construct complex, keyboard-navigable interfaces that run directly within terminal emulators. The framework distinguishes itself through a reactive architecture and a CSS-based layout engine. It uses a reactive attribute system to automatically track state changes and trigger targeted int
Provides systems for managing background operations and concurrency without blocking the main thread.
XState is a statechart logic library and finite state machine framework used to model complex application behavior. It provides a system for defining states, events, and transitions to govern how a system responds to inputs through a formal schema. The project includes a visual state machine editor that allows for the design of state machine diagrams which automatically generate the corresponding logic and code. It implements an actor model to manage independent concurrent entities that communicate via asynchronous events to coordinate behavioral flows. The framework covers event-driven stat
Coordinates asynchronous tasks and side effects that execute in tandem with state transitions and actor lifecycles.
Async is a JavaScript asynchronous flow library designed to manage the execution and coordination of asynchronous tasks in Node.js and the browser. It provides functional utilities to wrap, process, and orchestrate complex asynchronous workflows. The library distinguishes itself through a comprehensive task orchestrator that handles dependency graphs to resolve circular references and manages concurrent task queues. It includes a unification bridge that allows callback-style and promise-based functions to operate within the same execution interface. The project covers several primary capabil
Acts as a comprehensive orchestrator for managing complex asynchronous task dependencies, queues, and concurrency limits.
GPT Researcher is an autonomous agent framework designed to automate the process of gathering, synthesizing, and documenting information from diverse web and local sources. It functions as a research-oriented execution environment that orchestrates specialized agents to perform complex, multi-branch research tasks, transforming raw data into structured, factual, and cited reports. The project distinguishes itself through a graph-based orchestration layer that manages state transitions and information flow between specialized agents. It employs recursive tree-search execution to explore comple
Manages long-running research processes by handling concurrent data retrieval and real-time progress updates through non-blocking callback mechanisms.
EventBus is a publish-subscribe messaging library designed to facilitate decoupled communication between components in Java applications. It functions as a central hub where producers dispatch events that are routed to subscribers based on the class type of the payload. By using annotation-based markers, the system maps event handlers to specific data types, allowing different parts of an application to exchange information without requiring direct references between classes. The library distinguishes itself through a focus on performance and execution control. It utilizes a compile-time inde
The Event Bus library allows configuring custom thread pools, event buses, and error handling scopes to manage background task execution and failure recovery within application logic.
Redux-Saga is a middleware for managing complex asynchronous flows and side effects in Redux applications. It functions as an asynchronous state orchestrator and side effect manager that uses JavaScript generator functions to coordinate concurrent tasks and long-running background processes tied to a global state store. The system utilizes a generator-based effect middleware to handle external I/O and API requests outside of the main application logic. It provides a mechanism to start, pause, and cancel multiple asynchronous operations, allowing the application to prevent race conditions and
Coordinates concurrent tasks and long-running background processes tied to a global state store.
Redux-Saga is a middleware library for Redux applications that manages asynchronous data flows and complex side effects. It serves as a decoupled state management effect layer and workflow orchestrator, utilizing JavaScript generator functions to pause and resume asynchronous operations without blocking the application. The library distinguishes itself by using generators to manage sequential or parallel tasks and state transitions outside of the main user interface thread. This approach allows for the coordination of complex asynchronous workflows, such as multi-step data fetching and API ca
Implements a framework for managing concurrent background processes and non-blocking event loops.
This project is an AI code review tool and asynchronous task orchestrator designed to analyze uncommitted code changes and architectural decisions. It functions as an LLM agent integration plugin and cross-model workflow bridge, connecting different large language model agents to delegate engineering tasks and synchronize session context. The system enables multi-model orchestration to cross-reference design decisions and pressure-test architectural assumptions. It provides mechanisms to export session threads and transfer engineering context between separate AI coding environments, allowing
Manages concurrent background processes and non-blocking event loops for long-running technical investigations.
Bluebird is a JavaScript promise library designed for managing asynchronous operations with a custom promise implementation. It provides a framework for controlling promise lifecycles and orchestrating non-blocking programming patterns. The library distinguishes itself with an asynchronous debugging toolkit that captures long stack traces across asynchronous boundaries and a global handler for unhandled promise rejections. It includes a predicate-based error filtering system to target specific exception types and a mechanism for the deterministic cleanup of system resources. It covers a broa
Coordinates concurrent or sequential tasks while enforcing strict execution time limits.
This framework provides a set of architectural principles and design patterns for building production-ready autonomous agents. It focuses on structuring automated systems that maintain consistent execution, manage complex internal states, and support reliable error recovery through a state machine-based methodology. The system distinguishes itself by integrating human-in-the-loop orchestration directly into automated workflows. By incorporating manual oversight and validation checkpoints, it ensures safety and accuracy during critical decision-making processes. The framework also emphasizes d
Decouples task initiation from execution using asynchronous message queues for reliable background processing.
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
Manages complex sequences of network and computational operations to maximize system throughput through efficient non-blocking task execution.
Bytebot is an LLM desktop automation framework and virtual Linux desktop environment. It enables AI agents to plan and execute mouse and keyboard actions on a virtual computer using natural language, allowing for autonomous desktop automation and the integration of legacy systems that lack native APIs. The system operates as an LLM API gateway and a Model Context Protocol server, routing requests across multiple language model providers with integrated load balancing and rate limiting. It provides isolated, containerized environments where agents use visual reasoning to interpret screenshots
Manages the lifecycle of asynchronous jobs through a programmatic REST API for queuing and tracking.
Swift NIO is a low-level, event-driven network framework for the Swift language. It serves as an asynchronous network protocol stack and I/O library designed to build high-performance network servers and clients that handle thousands of simultaneous connections. The framework functions as a high-concurrency network engine that dispatches events across multiple CPU cores. It enables the implementation of custom network protocols by processing raw bytes through a sequence of reusable data transformation handlers. The system provides capabilities for non-blocking I/O multiplexing, asynchronous
Orchestrates complex asynchronous network tasks and workloads across multiple CPU cores.
This project is a remote file transfer server and asynchronous download orchestrator. It functions as a backend service that manages a queue of remote file transfer requests to coordinate the download of files from the web to a remote storage destination. The system operates as a distributed download coordinator, scheduling and tracking the progress of file transfers across different network nodes. It routes data requests from a client to a remote file system and utilizes asynchronous task execution to process heavy file operations in the background. The server includes capabilities for queu
Functions as an asynchronous task orchestrator for processing heavy file transfers in the background.
Dramatiq is a distributed task queue and workload manager used to offload function execution to background workers. It functions as an asynchronous task orchestrator that enables the distribution of computational tasks across a cluster using a pluggable transport layer supporting RabbitMQ and Redis. The framework provides specialized tools for complex task orchestration, including the ability to link background jobs into sequences, pipelines, and barriers. It further manages distributed concurrency through the use of shared mutexes, rate limiters, and exponential backoff retries to prevent re
Provides a framework for linking background jobs into sequences, pipelines, and barriers to orchestrate complex asynchronous workflows.
GRR 是一个分布式事件响应平台和异步取证任务编排器。它作为一个远程取证框架,旨在在安全事件响应期间从远程主机收集和分析易失性数据、系统内存和数字取证工件。 该系统作为远程端点分类系统运行,利用协调架构来管理智能体集群。它支持跨多个系统执行调查任务,允许在大型机器集群中搜索文件和注册表,以识别受损主机。 该平台提供数字取证分析功能,包括分析原始文件系统的能力以及生成按时间顺序排列的系统事件时间线。它还包括用于跟踪资源使用情况和调度周期性取证任务的企业集群监控工具。
Implements a non-blocking message processing system to schedule and execute forensic jobs across a fleet of targets.
Vibe-tools is a command-line interface that provides a unified way to query multiple AI models, analyze codebases, plan and execute complex tasks, search the web, and analyze YouTube videos. It combines several distinct tools into a single CLI: a multi-model AI query tool, an AI codebase analyzer, a task automation CLI, a web-enabled AI assistant, and a YouTube video analysis CLI. The tool can send prompts to any supported AI model, retrieve documentation from configured sources, and generate implementation plans by analyzing codebase files with multiple AI models. It differentiates through i
Manages concurrent AI queries, web searches, and browser automations using an asynchronous runtime.
Curio 是一个用于结构化并发和异步网络编程的 Python 库。它作为一个框架,利用非阻塞 Socket 和高吞吐量 I/O 来处理数千个并发 TCP 连接。 该库将异步操作组织成父子协程的层级结构,以确保依赖任务的可靠终止和清理。它提供了一套通过任务组和超时来协调这些并发操作的工具包。 该框架涵盖了广泛的并发管理功能,包括通过队列进行任务间通信,以及使用锁和信号量进行共享资源同步。它还支持执行外部进程,并将阻塞工作卸载到单独的线程,以保持事件循环的响应能力。
Implements an orchestrator for coordinating concurrent operations via non-blocking event loops and task groups.