如何将time.Duration类型传递给go函数？

Question

我正在学习GOLANG，特别是它的并发能力。

尝试进一步开发其中一个worker_pool示例，以便每个worker接收一个作业ID和一个作业负载，以作业的随机持续时间表示。

time.sleep命令使用持续时间来等待分配的纳秒数，这是随机计算的。

代码看起来像这样......

//worker_pool improved example

package main

import "fmt"
import "time"
import "math/rand"

// Here's the worker, of which we'll run several
// concurrent instances. These workers will receive
// work on the `jobs` channel and send the corresponding
// results on `results`. We'll sleep a random number of seconds between
// 1 and 5 to simulate an expensive task.
func worker(id int, jobs <-chan int, loads <-chan time.Duration, results chan<- int) {
   for j := range jobs {
        fmt.Println("worker", id, "started  job", j, time.Now())
        time.Sleep(loads*time.Second)  
        fmt.Println("worker", id, "finished job", j, time.Now())
        results <- j * 2
    }
}

func main() {

    // In order to use our pool of workers we need to send
    // them work and collect their results. We make 2
    // channels for this.
    jobs := make(chan int)
    loads := make(chan time.Duration)
    results := make(chan int)

    // This starts up 3 workers, initially blocked
    // because there are no jobs yet.
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }

    // Here we send 24 `jobs` and then `close` that
    // channel to indicate that's all the work we have.
    for j := 1; j <= 24; j++ {
        jobs <- j
        r := rand.New(rand.NewSource(99))
        load := r.Int63n(5000000)
        loads <- load
    }
    close(jobs)
    close(loads)


    // Finally we collect all the results of the work.
    for a := 1; a <= 24; a++ {
        <-results
    }
}

我一直收到这个错误消息......

prog.go:18:33：无法将load（type <-chan int）转换为time.Duration

prog.go:36:18：调用worker的参数不足有（int，chan int，chan int）想要（int，<-chan int，<-chan int，chan < - int）

prog.go:45:15：不能在send中使用load（类型int64）作为int类型

我究竟做错了什么？

Answer 1

另一答案