golang之channel

Buffered Channels

package main

import "fmt"

func main() {

	ch := make(chan int, 2)

	ch <- 1

	ch <- 2

	fmt.Println(<-ch)

	fmt.Println(<-ch)

}

如果操作一个空的channel会怎么样呢？

package main

import "fmt"

func main() {

	ch := make(chan int, 2)

	ch <- 1

	ch <- 2

	fmt.Println(<-ch)

	fmt.Println(<-ch)

	v, ok := <-ch

	fmt.Println(v,ok)

}

fatal error: all goroutines are asleep - deadlock!

如果make函数不指定buffer length，会怎么样呢？

func main() {

	ch := make(chan int)

	ch <- 1

	fmt.Println(<-ch)

}

fatal error: all goroutines are asleep - deadlock!

上述例子中sender，receiver都是同一个线程。

如果sender，receiver是不同线程会怎么样呢？

package main

import "fmt"

import "time"

func WriteChannel(c chan int, v int) {

	fmt.Printf("write %d to channel\n", v)

	c <- v

}

func main() {

	c := make(chan int)

	go WriteChannel(c,1)

	fmt.Println(<-c)

	time.Sleep(100 * time.Millisecond)

	fmt.Printf("Done\n")

}

运行又正常了。

巴特西

golang之channel

Buffered Channels

最新文章

热门文章