Popularity
2.8
Growing
Activity
0.1
Declining
25
2
7
Programming language: Go
Tags:
Goroutines
Latest version: v0.1.4
threadpool alternatives and similar packages
Based on the "Goroutines" category
-
semaphore
Semaphore pattern implementation with timeout of lock/unlock operations based on channel and context. -
Hunch
Hunch provides functions like: All, First, Retry, Waterfall etc., that makes asynchronous flow control more intuitive. -
go-tools/multithreading
Manage a pool of goroutines using this lightweight library with a simple API. -
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. -
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
Oversight is a complete implementation of the Erlang supervision trees.
Do you think we are missing an alternative of threadpool or a related project?
Popular Comparisons
|
SaaSHub - Software Alternatives and Reviews
View more from us
|
README
Golang Threadpool implementation
Scalable threadpool implementation using Go to handle the huge network trafic.
Install
go get github.com/shettyh/threadpool
Usage
Threadpool
- Implement
Runnableinterface for tha task that needs to be executed. For example
type MyTask struct { }
func (t *MyTask) Run(){
// Do your task here
}
- Create instance of
ThreadPoolwith number of workers required and the task queue sizepool := threadpool.NewThreadPool(200,1000000) - Create Task and execute
task:=&MyTask{} pool.Execute(task) - Using
Callabletask ``` type MyTaskCallable struct { }
func (c *MyTaskCallable) Call() interface{} { //Do task return result }
//Execute callable task task := &MyTaskCallable{} future := pool.ExecuteFuture(task)
//Check if the task is done isDone := future.IsDone() // true/false
//Get response , blocking call result := future.Get()
- Close the pool
pool.Close()
### Scheduled threadpool
- Create instance of `ScheduledThreadPool` with number of workers required
schedulerPool:= threadpool.NewScheduledThreadPool(10)
- Create Task and schedule
task:=&MyTask{} pool.ScheduleOnce(task, time.Second*20) // Time delay is in seconds only as of now
- Close the pool
pool.Close()