【每日一库】parallel: Go 语言并行处理库

地址：https://github.com/ryanskidmore/parallel

安装

go get -u github.com/ryanskidmore/parallel

使用

package main

import (
    "log"
    "fmt"

    "github.com/ryanskidmore/parallel"
)

func main() {
    p := parallel.New() // Create a new instance of parallel
    worker, err := p.NewWorker("worker1", &parallel.WorkerConfig{Parallelism: 1}) // Create a new worker
    if err != nil {
        log.Fatalf("FATAL: Failed to create new worker: %v", err)
    }
    worker.SetExecution(func(wh *parallel.WorkerHelper, args interface{}) { // Set the worker execution function
        fmt.Println(args)
        wh.Done()
    })
    worker.Start(interface{}("Test String")) // Start with worker with specified args
    worker.Wait() // Wait for the worker to complete
}