Go中的併發例程

Question

我想編寫三個併發例程來互相發送整數。現在，我已經實現了兩個發送整數的併發例程。

package main 
import "rand" 

func Routine1(commands chan int, responses chan int) { 
    for i := 0; i < 10; i++ { 
     i := rand.Intn(100) 
    commands <- i 
    print(<-responses, " 1st\n"); 
} 
close(commands) 
} 

func Routine2(commands chan int, responses chan int) { 
for i := 0; i < 1000; i++ { 
    x, open := <-commands 
    if !open { 
     return; 
    } 
    print(x , " 2nd\n"); 
    y := rand.Intn(100) 
    responses <- y 
} 
} 

func main() 
{ 
    commands := make(chan int) 
    responses := make(chan int) 
    go Routine1(commands, responses) 
    Routine2(commands, responses) 
} 

然而，當我要新增想要從上面的程序發送和接收整數/另一個例程，它給像「扔！：所有夠程都睡着了 - 死鎖」的錯誤。以下是我的代碼：

package main 
import "rand" 

func Routine1(commands chan int, responses chan int, command chan int, response chan int) { 
for i := 0; i < 10; i++ { 
    i := rand.Intn(100) 
    commands <- i 
    command <- i 
    print(<-responses, " 12st\n"); 
    print(<-response, " 13st\n"); 
} 
close(commands) 
} 

func Routine2(commands chan int, responses chan int) { 
for i := 0; i < 1000; i++ { 
    x, open := <-commands 
    if !open { 
     return; 
    } 
    print(x , " 2nd\n"); 
    y := rand.Intn(100) 
    responses <- y 
} 
} 

func Routine3(command chan int, response chan int) { 
for i := 0; i < 1000; i++ { 
    x, open := <-command 
    if !open { 
     return; 
    } 
    print(x , " 3nd\n"); 
    y := rand.Intn(100) 
    response <- y 
} 
} 

func main() { 
    commands := make(chan int) 
    responses := make(chan int) 
    command := make(chan int) 
    response := make(chan int) 
    go Routine1(commands, responses,command, response) 
    Routine2(commands, responses) 
    Routine3(command, response) 
} 

任何人都可以幫助我，我的錯誤在哪裏？任何人都可以幫助我，是否可以創建雙向通道或者是否可以爲int，string等創建公共通道？

Answer 1

您還沒有在main函數中聲明command和response變量。

func main() { 
    commands := make(chan int) 
    responses := make(chan int) 
    go Routine1(commands, responses, command, response) 
    Routine2(commands, responses) 
    Routine3(command, response) 
}