golang 初体验 - channel

channel 分为两种:

1. 无缓冲 channel

2. 缓冲 channel

无缓冲 channel 的使用必须遵循一个原则:推送和读取必须同时存在,否则就发生死锁

先上代码:

这里定义了一个 int 型的信道 c1,然后通过辅助协程并行给 c1 推送 v(就是 i)然后又在主协程读取。

输出:

有缓冲 channel 必须遵循一个原则:要确保 channel 缓冲的个数与推送、读取成比例

输出:

这里定义了一个缓冲区长度为3的 channel,然后推送3条消息,接着循环读取这个 channel,直到 channel 为空。

注意 close(c2)必须有,不然就是死锁,跟上篇文章的死锁情况1是一个道理,close()语句的作用就是告诉计算机我这个 channel 关闭了,不会再接收任何消息啦,故,主携程不会阻塞而发生死锁。

升级一下代码,使用辅助携程实现:

调用:

75行便是使用辅助携程实现给 c3 推送消息

再升级一下,我们用 channel 来实现一个单发单收的队列:

调用:

93行模拟了真实推送情况,每隔2秒推送一个消息,而主携程这里一直在等待,为什么没有死锁?

因为96行   :)

不要通过共享内存来通信,而应该通过通信来共享内存

原文地址:https://www.cnblogs.com/Eysa/p/10406392.html

时间: 2024-11-11 08:22:09

golang 初体验 - channel的相关文章

golang 初体验 - 令人惊叹的语法 - defer.1

在我们编程时,难免遇见 流.远程连接.文件等 io 操作,为了高性能,我们不得不打开和关系这些 io 对象. 在 java.C# 语言里这些打开和关闭的操作都需要程序员自己选择操作时机,一般是在 io 操作完成之后就关闭它. 但是在 go 语言里提供了一种更优雅的方式:defer.翻译为:延迟. 先上代码: 输出: 因为 defer 关键字 foo2 中的 foo1 被延迟了,延迟到 foo2 return 之前调用,所以产生了 foo1 foo2 foo1 的结果. 有什么用呢? 太爽了,比如

Flume 实战(1) -- 初体验

前言: Flume-ng是数据收集/聚合/传输的组件, Flume-ng抛弃了Flume OG原本繁重的zookeeper和Master, Collector, 其整体的架构更加的简洁和明了. 其基础组件就Agent进程, 内部又可以细分为Source, Channel, Sink三个组件, Source是数据的输入源, channel作为消息的管道, 而sink是作为数据流的输出, Source可以配置多个channel, sink和channel一一对应. *) 初体验Flume-ng 以C

WCF之初体验

什么是WCF? WCF的全称是:Windows通信基础(WindowsCommunication Foundation),本质来讲,他是一套软件开发包. WCF和WebService的区别 Webservice:严格来说是行业标准,不是一种技术,使用XML扩展标记语言来表示数据(这个是跨语言和平台的关键.) WCF其实一定程度上就是ASP.NET WebService,因为它支持Web Service的行业标准和核心协议,因此ASP.NET Web Service和WSE能做的事情,它几乎都能胜

初探go-golang语言初体验

2017/2/24 一.初体验 1.环境 wget https://storage.googleapis.com/golang/go1.8.linux-amd64.tar.gz tar -C /usr/local -xzf go1.8.linux-amd64.tar.gz cat <<'_EOF' >>/etc/profile #golang export PATH=$PATH:/usr/local/go/bin export GOPATH=/opt/go _EOF source 

Netty初体验

一.概述 Netty基于NIO的网络编程框架,是一个封装了NIO复杂的底层细节,可以拿来开发高并发的服务端和客户端的程序,简单直白你可以理解它就是一个好用的处理socket的东西就行啦. 二.Netty初体验 首先,创建maven工程添加Netty依赖,新建两个包,一个是客户端,一个服务端,先来看看服务端代码,这个是服务器类,主要的逻辑都在这里实现. public class Server { public static void main(String[] args) throws Excep

每天一点GO语言——Linux环境下安装Go语言环境以及编写Go语言程序初体验

每天一点GO语言--Linux环境下安装Go语言环境以及编写Go语言程序初体验 一.安装Go语言环境 [[email protected] opt]# yum -y install wget git [[email protected] opt]# wget -c https://studygolang.com/dl/golang/go1.10.3.linux-amd64.tar.gz [[email protected] opt]# tar -zxvf go1.10.3.linux-amd64

erlang 初体验

最近测试了一下 erlang的坑... 如不出意外.... 大家第一眼看到这语法... 心里第一句一定是"我擦.这TM都是啥!!!!!" 没有变量!!! 没有结构体!!! 没有循环!!! 好吧,至少我是这样想的. 找了半天..连个if也不知道怎么写.. 这记录一些基本常识.. -module(module_name)  %%定义模块 括号内的要和文件名相同. -export([fun1/1 fun2/2]) %%这里是导出2个函数对外使用  函数名/参数名. 一个简单的函数定义如下 f

linux初体验

第一次听到linux这个'词语'是在一次偶然的朋友聊天中朋友提到的,之前压根没听到过'这个东西',所以我可以说是个linux的新新手,菜鸟都不算. 截至到目前,我已经开始linux系统运维学习有差不多10天时间了.在没接触linux之前,我对它的认识仅仅是:它是个计算机系统.决定学习linux系统运维之前,自我以为运维应该是对系统的一些日常维护之类的,不会很难的东西,我更希望运维是个不难的东西,我个人很笨,对难的东西可能接受的很慢,所以我愿意认为运维是很简单的,这样我就可以轻轻松松的掌握运维相关

【Spark深入学习 -15】Spark Streaming前奏-Kafka初体验

----本节内容------- 1.Kafka基础概念 1.1 出世背景 1.2 基本原理 1.2.1.前置知识 1.2.2.架构和原理 1.2.3.基本概念 1.2.4.kafka特点 2.Kafka初体验 2.1 环境准备 2.2 Kafka小试牛刀 2.2.1单个broker初体验 2.2.2 多个broker初体验 2.3 Kafka分布式集群构建 2.3.1 Kafka分布式集群构建 2.3.2 Kafka主题创建 2.3.3 生产者生产数据 2.3.4消费者消费数据 2.3.5消息的