14 lines
226 B
Go
14 lines
226 B
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
func PollJobWorker(id int, jobs <-chan int) {
|
|
for job := range jobs {
|
|
fmt.Printf("Worker %d: memproses poll job %d\n", id, job)
|
|
time.Sleep(50 * time.Millisecond)
|
|
}
|
|
}
|