Golang实现生产者和消费者

packagemain

铜梁ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为成都创新互联公司的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：028-86922220（备注：SSL证书合作）期待与您的合作！

import(

"fmt"

"sync"

)

//实现一个生产者和消费者

/*生产者产生数据添加到通道里面，消费者消费数据从通道里面

不带缓存实现

*/

funcmain(){

ch:=make(chanint)

varwgsync.WaitGroup

wg.Add(2)

goproducers(wg,ch)

goconsumer(wg,ch)

wg.Wait()

}

//生产者

funcproducers(wg*sync.WaitGroup,chchanint){

fori:=0;i10;i++{

fmt.Println("send:",i)

ch-i

}

close(ch)

wg.Done()

}

//消费者

funcconsumer(wg*sync.WaitGroup,chchanint){

forv:=rangech{

fmt.Println("recv:",v)

}

wg.Done()

}

���$�

go语言中channel的问题

第一个问题，打开文件应添加"|os.O_WRONLY"

file, err := os.OpenFile("data.dat",os.O_CREATE|os.O_APPEND|os.O_WRONLY,0777)

第二个问题，将Count方法中的 "ch-i"放到方法的最后一行就可以了。

因为一旦“ch-i"执行了，main方法中的 "-ch"就会执行通过当所有的"-ch"执行完后程序就结束了。但这时Count的线程方法还来不及执行完（打开文件的速度相对较慢），所以仅仅执行一次文件操作就结束了

Go语言中怎样判断数据类型

一般来说，我们不会直接使用ASCII码来处理，因为这样不够直观。比如你说的判定输入是否是字母，是否是数字，那么有个比较直观的方法来处理。如果你看过ASCII码表，那么你就知道字数和字母在ASCII码表中都是连续的，所以这个就比较好解决了。

判定字符ch是否是数字：

if(ch='0' ch='9')

判定字符ch是否是字母：

if(ch='a' ch='z' || ch='A' ch='Z')

当然，有已经定义好的库函数用来判定是否数字和字母，不要加加载头文件ctype.h

判定字符ch是否是数字：

if(isalnum(ch));

判定字符ch是否是字母：

if(isalpha(ch));

这两个函数都是判定成立，结果是true也就是1，判定不成立，结果是false，也就是0.

Go 语言 channel 的阻塞问题

Hello，大家好，又见面了！上一遍我们将 channel 相关基础以及使用场景。这一篇，还需要再次进阶理解channel 阻塞问题。以下创建一个chan类型为int，cap 为3。

channel 内部其实是一个环形buf数据结构 ，是一种滑动窗口机制，当make完后，就分配在 Heap 上。

上面，向 chan 发送一条“hello”数据：

如果 G1 发送数据超过指定cap时，会出现什么情况？

看下面实例：

以上会出现什么，chan 缓冲区允许大小为1，如果再往chan仍数据，满了就会被阻塞，那么是如何实现阻塞的呢？当 chan 满时，会进入 gopark，此时 G1 进入一个 waiting 状态，然后会创建一个 sudog 对象，其实就sendq队列，把 200放进去。等 buf 不满的时候，再唤醒放入buf里面。

通过如下源码，你会更加清晰：

上面，从 chan 获取数据：

Go 语言核心思想：“Do not communicate by sharing memory; instead, share memory by communicating.” 你可以看看这本书名叫：Effective Go

如果接收者，接收一个空对象，也会发生什么情况？

代码示例 ：

也会报错如下：

上面，从 chan 取出数据，可是没有数据了。此时，它会把 接收者 G2 阻塞掉，也是和G1发送者一样，也会执行 gopark 将状态改为 waiting，不一样的点就是。

正常情况下，接收者G2作为取出数据是去 buf 读取数据的，但现在，buf 为空了，此时，接收者G2会将sudog导出来，因为现在G2已经被阻塞了嘛，会把G2给G，然后将 t := -ch 中变量 t 是在栈上的地址，放进去 elem ，也就是说，只存它的地址指针在sudog里面。

最后， ch - 200 当G1往 chan 添加200这个数据，正常情况是将数据添加到buf里面，然后唤醒 G2 是吧，而现在是将 G1 的添加200数据直接干到刚才G2阻塞的t这里变量里面。

你会认为，这样真的可以吗？想一想，G2 本来就是已经阻塞了，然后我们直接这么干肯定没有什么毛病，而且效率提高了，不需要再次放入buf再取出，这个过程也是需要时间。不然，不得往chan添加数据需要加锁、拷贝、解锁一序列操作，那肯定就慢了，我想Go语言是为了高效及内存使用率的考虑这样设计的。（注意，一般都是在runtime里面完成，不然会出现象安全问题。）

总结 ：

chan 类型的特点：chan 如果为空，receiver 接收数据的时候就会阻塞等待，直到 chan 被关闭或者有新的数据到来。有这种个机制，就可以实现 wait/notify 的设计模式。

相关面试题：

文章标题：go语言中ch用法 go语言%v
网址分享：http://pwwzsj.com/article/dosgoog.html