16 个仓库
Lightweight concurrency primitives for managing high-volume task execution in asynchronous runtimes.
Distinct from Thread Pools: Focuses on goroutine-specific concurrency models rather than generic thread pools.
Explore 16 awesome GitHub repositories matching programming languages & runtimes · Goroutine Pools. Refine with filters or upvote what's useful.
Hey is a command-line utility designed for HTTP load testing and API performance benchmarking. It functions as a concurrent request generator that simulates high volumes of traffic against target endpoints to evaluate service responsiveness, throughput, and stability under load. The tool distinguishes itself by integrating specialized modules for cryptographic request signing and internal service authorization. It supports the generation of digital signatures for decentralized social protocols and validates backend requests using shared secret tokens, allowing for secure interaction with prot
Utilizes lightweight goroutine-based worker pools to simulate high-volume traffic against target endpoints.
RxSwift is a reactive programming library for Swift that provides a framework for managing push-based data flows and composing asynchronous, event-based programs. It utilizes observable sequences and functional operators to transform and filter asynchronous sequences through a declarative approach. The library is distinguished by its ability to link asynchronous data streams directly to user interface elements, automating view updates via reactive data binding. It includes specialized tools for tracking UI control properties and events on the main thread, as well as the ability to encapsulate
Represents operations that finish with a success or error signal without producing data elements.
Listmonk is a self-hosted email marketing platform and newsletter manager designed for high-volume bulk email distribution and transactional messaging. It provides a centralized system for organizing large subscriber databases and executing automated marketing campaigns directly from your own infrastructure. The platform distinguishes itself through its reliance on a relational database backend, which enables dynamic subscriber segmentation using complex query filtering at the time of delivery. It utilizes a concurrent worker pool to manage high-throughput email dispatch and incorporates a se
Manages high-throughput email dispatch using a concurrent worker pool for efficient parallel processing.
This project is a command-line utility designed for HTTP load testing and network stress testing. It functions as a benchmarking tool that generates high volumes of concurrent traffic to evaluate the performance, reliability, and throughput capacity of web applications and APIs under sustained load. The tool allows for precise control over traffic generation by enabling users to configure request parameters, including custom headers, authentication credentials, and specific HTTP methods. It manages load through a worker-pool system that regulates request frequency, allowing for both time-boun
Uses lightweight goroutines to manage high-concurrency network request execution.
CS-Base is a comprehensive educational platform and technical repository designed to support software engineers in mastering backend architecture, artificial intelligence engineering, and career development. It functions as a centralized knowledge hub that combines illustrated theoretical tutorials with practical, project-based learning to bridge the gap between foundational computer science concepts and professional industry requirements. The project distinguishes itself by integrating a robust career mentorship framework with advanced AI engineering resources. It provides users with tools f
Blocks execution until a group of concurrent tasks finishes by tracking an atomic counter and signaling waiting threads.
This tool is a command-line utility designed for automated web resource discovery, fuzzing, and application structure mapping. It functions as a security-focused scanner that identifies hidden files, directories, parameters, and virtual hosts by injecting payloads into HTTP requests. By systematically testing how servers handle various inputs, it assists in mapping the architecture of web applications and uncovering potential security vulnerabilities. The tool distinguishes itself through a highly concurrent engine that manages asynchronous request execution and recursive job orchestration. I
Utilizes a high-performance pool of goroutines to execute parallel network requests for efficient large-scale discovery.
Ants is a goroutine pool library for Go that functions as a concurrent task orchestrator and resource consumption limiter. Its primary purpose is to manage and reuse a pool of goroutines to limit concurrency and reduce the memory allocation overhead associated with frequent thread creation. The system provides a runtime worker manager capable of adjusting pool capacity dynamically to respond to fluctuating workloads. To maintain stability, it includes panic recovery mechanisms that intercept runtime failures within worker threads to prevent a single failing task from crashing the entire appli
Provides a high-performance goroutine pool to manage and reuse long-lived concurrency primitives in Go.
This project provides a TypeScript software development kit for the Model Context Protocol, a standard designed to facilitate bidirectional communication between AI applications and external data sources or tools. It serves as a foundational framework for building both clients and servers, enabling language models to interact with external systems through a unified, decoupled interface. The SDK distinguishes itself by implementing a transport-agnostic connection layer that supports both local standard input-output streams and remote HTTP endpoints. It utilizes a JSON-RPC message bus to manage
Provides a mechanism for signaling the completion of asynchronous tasks to allow client-side resumption.
UniTask is a high-performance asynchronous task library designed specifically for the Unity game engine. It provides a specialized framework for managing background operations and complex game logic, enabling developers to utilize modern asynchronous patterns while maintaining consistent frame rates during high-frequency engine updates. The library distinguishes itself through a zero-allocation architecture that prioritizes memory efficiency. By utilizing struct-based task representations and an internal object pooling system, it significantly reduces garbage collection pressure compared to s
Bypasses the asynchronous state machine for tasks that complete synchronously, executing continuations directly on the current stack.
conc is a Go concurrency library and structured concurrency framework providing primitives for managing parallel tasks, mapping slices, and collecting results. It implements a system for spawning scoped tasks to ensure all child processes complete before their parent exits. The library includes a goroutine pool manager to limit active concurrent processes and a panic-safe task runner that catches panics in goroutines and propagates stack traces to the parent. It also provides a concurrent map-reduce tool for transforming data slices and processing streams in parallel while maintaining the ori
Provides a goroutine pool manager to limit active concurrent processes and prevent system resource exhaustion.
Zinx is a lightweight TCP server framework written in Go that provides a structured foundation for building scalable network applications. It combines a goroutine-pool worker model for concurrency control with message-ID-based routing, enabling efficient packet dispatching to registered handler functions. The framework distinguishes itself through its modular plugin architecture, which organizes server components like routers, connections, and message modules as interchangeable plugins for extensibility. It uses packet-header length prefixing for reliable TCP stream framing, assigns a dedicat
Provides a fixed goroutine pool for handling client requests, controlling concurrency in the TCP server.
Bombardier is a concurrent HTTP load generator and performance benchmarking tool written in Go. It functions as a latency distribution analyzer and benchmarking utility designed to measure the throughput and response speed of HTTP services by simulating high-volume request loads. The tool provides specific capabilities for TLS benchmarking, supporting client certificate authentication and the ability to bypass server certificate verification. It distinguishes itself through the use of a token-bucket algorithm for precise request rate limiting and the use of templates to export benchmark resul
Uses lightweight Go concurrency to simulate massive numbers of simultaneous network connections.
Concurrent Ruby is a comprehensive concurrency toolkit for the Ruby language that provides thread-safe data structures, synchronization primitives, and asynchronous execution patterns. It implements core concurrency abstractions including an actor model framework where isolated actors communicate through asynchronous message passing, a future and promise system for composing non-blocking operations, and thread pool executors that manage reusable worker threads for concurrent task execution. The library distinguishes itself through a broad set of coordination mechanisms that go beyond basic th
Decrements an internal counter from any thread to signal completion of a work unit.
RxGo 是一个函数式响应式编程库,也是 ReactiveX 的 Go 语言实现。它作为一个异步流处理工具包,旨在利用可观察模式协调基于事件的程序和数据流。 该库支持构建异步处理管道,以转换、过滤和组合事件序列。其特色在于使用函数式操作符来组合这些管道,并提供了管理并发执行的机制。 该工具包涵盖了广泛的流编排功能,包括数据聚合、多流组合以及将流转换为静态数据结构。它内置了对错误恢复、用于调节数据生产速度的背压控制以及用于跨 CPU 核心并行处理的工作池的支持。
Provides goroutine pools to distribute stream processing tasks and execute transformations in parallel across CPU cores.
Tunny 是 Go 语言的 worker 池库和并发管理器。它作为并发任务调度器,限制并行处理作业的 worker 数量,以防止系统资源耗尽。 该项目支持在单个 worker 例程中维护持久状态,以避免重复的初始化成本。它还支持动态 worker 扩缩容,允许在不中断正在进行任务的情况下实时调整后台 worker 的数量。 该库提供了任务超时强制执行和 worker 生命周期管理机制,包括例程池的优雅关闭。它利用并发限制来限制活动 goroutine 的总数。
Provides lightweight goroutine pools for managing high-volume task execution in Go.
Bolts-Swift is a concurrency control framework designed to manage asynchronous workflows in native mobile applications. It provides a collection of primitives that allow developers to orchestrate background operations through a promise-based model, replacing deeply nested callback structures with chainable task sequences. The library distinguishes itself by offering granular control over task lifecycles and execution environments. It enables developers to define custom executors for specific threading contexts and provides mechanisms to manually signal the completion, error, or cancellation o
Provides mechanisms to manually signal the completion, error, or cancellation of background work.