workerpool Alternatives - Go Goroutines

Popularity

3.6

Growing

Activity

4.6

Declining

Stars 51

Watchers 4

Forks 8

Last Commit 11 days ago

Programming language: Go

Tags: Goroutines

Latest version: v1.1.6

workerpool alternatives and similar packages

Based on the "Goroutines" category

ants

9.1 8.1 workerpool VS ants

🐜⚡️A high-performance goroutine pool in Go, inspired by fasthttp.
goworker

8.8 0.0 workerpool VS goworker

goworker is a Go-based background worker
tunny

8.0 0.6 workerpool VS tunny

A goroutine pool for golang.
grpool

7.1 0.0 workerpool VS grpool

Lightweight Goroutine pool.
pool

6.9 0.0 workerpool VS pool

Go consumer goroutine pool for easy goroutine handling + time saving.
gowp

5.2 7.3 workerpool VS gowp

gowp is concurrency limiting goroutine pool.
Goflow

4.9 0.0 workerpool VS Goflow

Simply way to control goroutines execution order based on dependencies
go-floc

4.5 0.0 workerpool VS go-floc

Orchestrate goroutines with ease.
semaphore go

4.0 0.0 workerpool VS semaphore go

Fast resizable golang semaphore
GoSlaves

3.4 1.5 workerpool VS GoSlaves

Simple and Asynchronous Goroutine pool library.
gpool

3.4 4.4 workerpool VS gpool

manages a resizeable pool of context-aware goroutines to bound concurrency.
go-do-work

3.3 0.0 workerpool VS go-do-work

Dynamically resizable pools of goroutines which can queue an infinite number of jobs.
semaphore

3.2 7.2 workerpool VS semaphore

Semaphore pattern implementation with timeout of lock/unlock operations based on channel and context.
breaker

3.2 5.1 workerpool VS breaker

Flexible mechanism to make execution flow interruptible.
async

3.2 2.5 workerpool VS async

A safe way to execute functions asynchronously, recovering them in case of panic.
threadpool

2.8 0.1 workerpool VS threadpool

Golang threadpool implementation.
gollback

2.4 4.7 workerpool VS gollback

asynchronous simple function utilities, for managing execution of closures and callbacks.
artifex

2.4 3.2 workerpool VS artifex

Simple in-memory job queue for Golang using worker-based dispatching.
Hunch

2.1 5.4 workerpool VS Hunch

Hunch provides functions like: All, First, Retry, Waterfall etc., that makes asynchronous flow control more intuitive.
kyoo

1.9 3.9 workerpool VS kyoo

Provides an unlimited job queue and concurrent worker pools.
parallel-fn

1.8 0.0 workerpool VS parallel-fn

Run functions in parallel.
gohive

1.8 5.8 workerpool VS gohive

A highly performant and easy to use Goroutine pool for Go.
cyclicbarrier

1.7 4.6 workerpool VS cyclicbarrier

CyclicBarrier for golang.
Bifrost

1.6 0.0 workerpool VS Bifrost

Golang query-able job queue
caster

1.5 3.2 workerpool VS caster

Dead simple and performant message broadcaster (pubsub) for Go
go-tools/multithreading

1.3 1.1 workerpool VS go-tools/multithreading

Manage a pool of goroutines using this lightweight library with a simple API.
routine

1.1 6.3 workerpool VS routine

go routine control with context, support: Main, Go, Pool and some useful Executors.
conexec

1.0 6.7 workerpool VS conexec

A concurrent toolkit to help execute funcs concurrently in an efficient and safe way.It supports specifying the overall timeout to avoid blocking and uses goroutine pool to improve efficiency.
go-waitgroup

1.0 4.3 workerpool VS go-waitgroup

Like sync.WaitGroup with error handling and concurrency control.
go-trylock

1.0 3.4 workerpool VS go-trylock

TryLock support on read-write lock for Golang.
Syncs

0.7 4.4 workerpool VS Syncs

additional synchronization primitives
WorkerGo

0.6 0.4 workerpool VS WorkerGo

A worker pool implementation for Go
Flow

0.6 4.3 workerpool VS Flow

FBP / pipelines
sworker

0.5 8.9 workerpool VS sworker

Go easy worker setup for your code
queue

0.3 0.9 workerpool VS queue

Gives you a sync.WaitGroup like queue group accessibility. Helps you to throttle and limit goroutines, wait for the end of the all goroutines and much more.
oversight

- - workerpool VS oversight

Oversight is a complete implementation of the Erlang supervision trees.

Do you think we are missing an alternative of workerpool or a related project?

Add another 'Goroutines' Package

Popular Comparisons

README

👨‍🔧 worker-pool

Go simple async worker pool.

📖 ABOUT

Contributors:

Rafał Lorenz

Want to contribute ? Feel free to send pull requests!

Have problems, bugs, feature ideas? We are using the github issue tracker to manage them.

📚 Documentation

For examples visit godoc#pkg-examples

For GoDoc reference, visit godoc.org

🚏 HOW TO USE

🚅 Benchmark

CPU: 3,3 GHz Intel Core i7

RAM: 16 GB 2133 MHz LPDDR3

➜  worker-pool git:(master) ✗ go test -bench=. -cpu=4 -benchmem
goos: darwin
goarch: amd64
BenchmarkWorker1-4                   3000000           453 ns/op          56 B/op          3 allocs/op
BenchmarkWorker1Parallel-4           3000000           506 ns/op          48 B/op          2 allocs/op
BenchmarkWorker100-4                 3000000           485 ns/op          56 B/op          3 allocs/op
BenchmarkWorker100Parallel-4         3000000           444 ns/op          48 B/op          2 allocs/op
BenchmarkWorkerNumCPU-4              3000000           467 ns/op          56 B/op          3 allocs/op
BenchmarkWorkerNumCPUParallel-4      3000000           431 ns/op          48 B/op          2 allocs/op
PASS
ok      worker-pool 11.570s

🏫 Basic example

package main

import (
    "fmt"
    "sync"

    "github.com/vardius/worker-pool"
)

func main() {
    var wg sync.WaitGroup

    poolSize := 1
    jobsAmount := 3
    workersAmount := 2

    // create new pool
    pool := workerpool.New(poolSize)
    out := make(chan int, jobsAmount)

    pool.Start(workersAmount, func(i int) {
        defer wg.Done()
        out <- i
    })

    wg.Add(jobsAmount)

    for i := 0; i < jobsAmount; i++ {
        pool.Delegate(i)
    }

    go func() {
        // stop all workers after jobs are done
        wg.Wait()
        close(out)
        pool.Stop()
    }()

    sum := 0
    for n := range out {
        sum += n
    }

    fmt.Println(sum)
    // Output:
    // 3
}

📜 [License](LICENSE.md)

This package is released under the MIT license. See the complete license in the package

*Note that all licence references and agreements mentioned in the workerpool README section above are relevant to that project's source code only.

workerpool

goworker is a Go simple async worker pool.