gopool is a Go library that provides a goroutine pool for efficient task execution. It allows you to manage a fixed number of goroutines to execute tasks concurrently, reducing the overhead of creating and destroying goroutines frequently.
syncgroup enhances Go's sync.WaitGroup with additional features such as panic recovery and custom panic handlers. It simplifies the management of goroutines, ensuring that any panics are handled gracefully and that all goroutines complete before proceeding.
taskgroup offers a way to group related tasks and manage their execution as a unit. It supports interruptible tasks and automatic error propagation, making it easier to handle errors and control the flow of concurrent tasks.
gostream provides a framework for executing tasks concurrently while ensuring that their callbacks are executed sequentially. This is useful for maintaining consistency when processing results from multiple concurrent operations.
gostreamch extends gostream by providing error handling capabilities. It allows you to submit tasks that may return errors and provides an error channel to retrieve these errors asynchronously.
gopoolch is an extension of gopool that includes custom panic and error handlers. It allows you to manage goroutines efficiently with built-in panic recovery and error handling mechanisms.
go get github.com/safeblock-dev/wrSystem Software Overview:
Device: MacBook Air, M1
System Version: macOS 14.1 (23B74)
Kernel Version: Darwin 23.1.0
| Benchmark | Iterations | Time (ns/op) | Memory (B/op) | Allocations (allocs/op) |
|---|---|---|---|---|
| Default | 17,376,734 | 321.1 | 88 | 4 |
| Gopool | 16,261,023 | 366.4 | 33 | 3 |
| WR | 15,597,608 | 368.4 | 33 | 3 |
| Conc | 16,494,992 | 411.0 | 66 | 4 |
| Ants | 16,887,066 | 415.0 | 40 | 3 |
| Pond | 6,872,601 | 901.6 | 32 | 3 |
| Benchmark | Iterations | Time (ns/op) | Memory (B/op) | Allocations (allocs/op) |
|---|---|---|---|---|
| Conc | 14,056,011 | 435.8 | 104 | 7 |
| WR | 11,183,976 | 505.8 | 112 | 7 |
| Benchmark | Iterations | Time (ns/op) | Memory (B/op) | Allocations (allocs/op) |
|---|---|---|---|---|
| Default | 1,875,888 | 3113 | 541 | 31 |
| Conc | 1,769,134 | 3469 | 707 | 41 |
| WR | 1,780,732 | 3699 | 707 | 41 |
| Benchmark | Iterations | Time (ns/op) | Memory (B/op) | Allocations (allocs/op) |
|---|---|---|---|---|
| WR | 1,714,483 | 3492 | 1680 | 59 |
| Run | 1,512,882 | 3975 | 1560 | 57 |