README
¶
Usage
worker.New() starts n * Workers goroutines running func on incoming parameters sent on the returned channel.
Example
package main
import (
"github.com/donutloop/toolkit/worker"
"log"
)
func main() {
workerHandler := func(parameter interface{}) {
v := parameter.(string)
log.Println(v)
}
queue := worker.New(2, workerHandler, 10)
queue <- "hello"
queue <- "world"
}
Documentation
¶
Overview ¶
Example ¶
package main
import (
"fmt"
"time"
"github.com/donutloop/toolkit/worker"
)
func main() {
workerHandler := func(parameter interface{}) (interface{}, error) {
v := parameter.(string)
return v + " world", nil
}
request, response, _ := worker.New(2, workerHandler, 10)
request <- "hello"
<-time.After(time.Millisecond * 250)
fmt.Println(<-response)
}
Output: hello world
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.