gochan基本使用详解

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《gochan基本使用详解》，主要内容是讲解gochan等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

1、有缓冲的chan 与无缓冲的chan

怎么理解这个缓冲，我个人的理解是是执行这个chan 操作的时候是否发送阻塞。
操作：读和写。
读取的时候，我们都应该要是阻塞的，例如我们的socket、的recv函数。当然取决于你设置的是阻塞的套接字还是非阻塞的套接字了。
无缓冲的chan，讲究读写对称，也就是你在读的时候会阻塞，看下面这个例子：ch是一个无缓冲的chan,在主线程里面，ch

func TestChan1(t *testing.T) {
	ch := make(chan int)
	

我们对此进行修改,同样的也是无缓冲的chan,只不过让读操作异步，也就是不是阻塞在主线程了，让主线程可以继续执行。

func TestChan1(t *testing.T) {
	ch := make(chan int)
	go func() {
		val := 

以上是无缓冲chan 的读操作，假设我们是先写呢？我们应该可以猜想到，写可能发生阻塞也可能不发生阻塞。那么无缓冲的chan 到底会不会阻塞呢？我们看下面的例子

func TestChan1(t *testing.T) {
	ch := make(chan int)
	ch 

运行之后，发生了死锁。
对此我们可以得出的初步结论是：无缓冲的chan 读写都是阻塞的。
同理我们对此进行修改

func TestChan1(t *testing.T) {
	ch := make(chan int)
	go func() {
		ch 

无缓冲的chan的介绍，到以上就结束，我们看一下有缓冲的chan。

2、有缓冲的chan

猜想一下有缓冲的chan 是什么存在缓冲，也就是说是读写操作哪个是非阻塞的，还是都是非阻塞的。我们看下面的例子。
第一个例子

func TestChan1(t *testing.T) {
	ch := make(chan int,1)
	ch 

先写入ch 然后读取。运行

这里我们得到结论：写是非阻塞。
第2 个例子：

func TestChan1(t *testing.T) {
	ch := make(chan int,1)
	

很显然我们可以猜到，会死锁。运行

对此我们对于有缓冲的chan得出的结论：读取是阻塞的。

同理，针对上面的修改：

func TestChan1(t *testing.T) {
	ch := make(chan int,1)
	go func() {
		val := 

对此我们对于chan有了一个基本的认识与使用。接下来看一下chan 几个应用实例。

3、利用chan 实现生产者消费者

生产者与消费者，说白了就是一个线程负责产生数据，另外一端消费数据。对应于我们的读写操作上来，生产者写数据，消费者读数据。对于该模型是不是，很容易利用chan来实现呢？假设我们现在是1个生产者，1个消费者，那么我们应该利用几个chan呢，很显然是一个chan 就够了，因为写入需要阻塞，那么我们的produce 是需要一个线程的，对于消费者，我们也需要一个线程，具体实现：

func TestChan1(t *testing.T) {
	ch := make(chan int,1)
	defer close(ch)
	go func() {
		for i := 0;i

针对接收数据，我们通常采用以下这种模式。

for {
 select {
   case 

4、利用chan 实现同步

两条线程交替打印，例如：1-100，两条线程交替打印。
分析一下这个操作，时间上我们利用的是chan的读取阻塞的特性，实际上就是利用chan 实现同步。

func TestChan1(t *testing.T) {
	ch1 := make(chan int)
	ch2 := make(chan int)
	go func() {
		for i := 0; i 

5、并发处理

假设我们有一个任务，这个任务可以分成很多份，每个任务处理的都是相同的内容，例如多线程查询，汇总。多线程上传。具体的chan 模板代码：

// eg1: 假设10条线程处理，采用10个chan的方式
var res = 0
func TestChan() {
	ch := make(chan int,1)
	closeCh := make(chan int,1)
	defer close(ch)
	for i := 1;i

运行结果

使用waitgroup

func WgTest() {
	ch := make(chan int, 1)
	closeCh := make(chan int,1)
	wg := sync.WaitGroup{}
	wg.Add(2)
	go Produce(ch,&wg)
	go Produce(ch,&wg)
	go Merge(ch,closeCh)
	wg.Wait()
	close(ch)
	

今天关于《gochan基本使用详解》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！