Golang使用channel进行奇偶数交替输出 @ 胡巴 | 星期四,二月 17 日,2022 年 | 1 分钟阅读 | 更新于 星期四,二月 17 日,2022 年

golang中使用channel相关知识控制协程交替输出奇偶数。

使用两个channel实现

package main

import (
	"fmt"
)

func main() {
	ch1 := make(chan int)
	ch2 := make(chan int)
	ch3 := make(chan struct{}) // 用于主协程阻塞,等待子协程执行完毕

	go func() {
		for i := 0; i < 10; i++ {
			<-ch1 // 阻塞,等待告知执行
			if i % 2 == 0 {
				fmt.Println("goroutine1:", i)
			}
			ch2<-i // 通知goroutine2执行
		}
		fmt.Println("goroutine1 done")
	}()

	go func() {
		for i := 0; i < 10; i++ {
			final := <-ch2 // 阻塞等待通知执行
			if i % 2 != 0 {
				fmt.Println("goroutine2:", i)
			}
			if final == 9 { // 如果final == 9 了,说明已经改结束了
				close(ch1)
				close(ch2)
				break
			}
			ch1<-i // 通知goroutine1执行
		}
		fmt.Println("goroutine2 done")
		ch3<-struct{}{} // 结束后通知主协程结束
	}()

	ch1<-0

	<-ch3
	fmt.Println("main done")
}

使用一个channel实现

package main

import "fmt"

func main() {
	c := make(chan int)
	completeCh := make(chan int) // 用来阻塞主协程等待子协程执行完毕
	go func() {
		for i := 0; i < 10; i++ {
			if i % 2 == 0 {
				fmt.Println("goroutine1:", i)
			}
			c<-i // 通知goroutine2
			<-c // 等待通知
		}
		close(c) // 关闭通道
		fmt.Println("goroutine1: done")
	}()

	go func() {
		defer func() {
			fmt.Println("goroutine2: done")
			completeCh<-10 // 通知主协程结束
		}()
		for {
			select { // 使用for-select来监听channel_c
			case i, ok := <-c: // 如果c被关闭,ok为false,标识结束
				if !ok {
					return
				}
				if i % 2 != 0 {
					fmt.Println("goroutine2:", i)
				}
				c<-i // 通知goroutine1继续执行
			}
		}
	}()

	<-completeCh
	fmt.Println("main:done")
}

公众号: 无限递归

alt 搜索公众号:无限递归

Copyright © 2017 - 2018 boboidea.com All Rights Reserved 波波创意软件工作室 版权所有 【转载请注明出处】

avatar
基本信息
  • 姓名:bobo
  • 花名:胡巴
  • 性别:男
  • 血型:O型
  • 星座:白羊座

联系方式

  • 所在地:上海
  • QQ:279250819
  • 微信号:wanghuiwoshinideyou
  • 电子邮件:279250819@qq.com

博客地址

公众号

alt 无限递归

待学习的东西

  • docker
  • k8s
  • flink
  • flutter
  • golang源码
  • redis底层
  • 消息中间价原理
  • zabbix
  • opentracing
  • grafana
工作经历
  • 2019.6 - 至今

    • 公司:萌推(上海突进网络科技有限公司)
    • 职位:中级PHP工程师 & 初级golang工程师
    • 荣誉:
      • 绩效A连续得主
      • 月度之星
      • 优秀个人奖
    • 所作所为:
      • 利用ES优化OMS、MMS管理系统商品列表查询
      • 利用消息队列、Redis、乐观锁优化商品审核流程
      • 利用Redis对商家端接口进行有效限流
      • 优化商品相关表索引,提升SQL查询速度
      • 商品中台构建,统一商品相关操作
      • 大表优化(数据分离、分表、大字段拆分)
      • 掌握所有商品核心流程
  • 2018.5 - 2019.5

    • 公司:DaDa英语(上海卓赞教育信息科技有限公司)
    • 职位:中级PHP开发工程师
    • 荣誉:无
    • 所作所为:
      • 利用ES优化教师CMS系统统计数据接口至500ms内
      • 工单系统开发及持续优化
      • 教师CMS系统的功能开发及持续优化
  • 2018.3 - 2018.5

    • 公司:波奇(上海)信息科技有限公司
    • 职位:初级PHP开发工程师
    • 荣誉:同下
    • 所做作为:如下
  • 2016.7 - 2018.3

    • 公司:光橙(上海)信息科技有限公司
    • 职位:初级PHP开发工程师
    • 荣誉:
      • 年度最佳进步奖
    • 所作所为:
      • 利用Redis提升商详接口最佳响应速度至50ms内
      • 利用Redis提升双11活动页可承受QPS至500以上
      • 利用Redis对接口进行简单限流
      • 与小伙伴合作提升搜索质量(ES初识)
      • 其他C端接口的开发及优化
      • B端商城老页面的维护及优化
SKILLS

编程语言

  • PHP
  • Golang
  • Shell
  • JAVA
  • JS
  • HTML\CSS

数据库

  • MySQL
  • Redis
  • 具有简单分表经验

消息中间件

  • RabbitMq
  • Kafka

文档撰写

  • Swagger
  • Markdown

技术框架

  • Laravel
  • gin

搜索引擎

  • ElasticSearch

抓包工具

  • Charles