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 exampletype 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{} err := pool.Execute(task) -
Using
Callabletasktype MyTaskCallable struct { } func (c *MyTaskCallable) Call() interface{} { //Do task return result } //Execute callable task task := &MyTaskCallable{} future, err := 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
ScheduledThreadPoolwith number of workers requiredschedulerPool:= 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()
