Go-并发模式总结(扇入模式,超时模式,callback模式等)

简介: Go-并发模式总结(扇入模式,超时模式,callback模式等)

Generator

Go-并发模式2(Patterns)https://blog.csdn.net/lady_killer9/article/details/120145534

https://blog.csdn.net/lady_killer9/article/details/120145534

一句话总结:返回channel,不断从channel接收

扇入模式

Go-并发模式2(Patterns)https://blog.csdn.net/lady_killer9/article/details/120145534

https://blog.csdn.net/lady_killer9/article/details/120145534


一句话总结:接收多个channel,并入一个channel并返回

超时模式

总体超时

Go-并发模式2(Patterns)https://blog.csdn.net/lady_killer9/article/details/120145534

https://blog.csdn.net/lady_killer9/article/details/120145534

一句话总结:循环前定时,结合select

单次超时

Go-并发模式2(Patterns)https://blog.csdn.net/lady_killer9/article/details/120145534

https://blog.csdn.net/lady_killer9/article/details/120145534

一句话总结:循环内定时,结合select

周期定时

Go-并发编程基础(goroutine、channel、select等)https://blog.csdn.net/lady_killer9/article/details/116144462

https://blog.csdn.net/lady_killer9/article/details/116144462

time与select一节


一句话总结:循环前定时,结合select

callback模式

go开启一个协程,并不知道什么时候会结束,其他语言一般会有callback,在go中,函数可以作为参数实现callback,这里再说一种channel实现callback的思路。

开启的协程,可以在结束后像一个channel中写入值,main routine中读取,即可实现阻塞直到完成。

package main
import (
  "fmt"
  "math/rand"
  "time"
)
func doSomething(event string,ch chan<-bool) {
  time.Sleep(time.Duration(rand.Intn(500))*time.Millisecond)
  ch<-true
}
func main() {
  ch := make(chan bool)
  go doSomething("event",ch)
  for{
    select {
    case <-ch:
      fmt.Println("finish...")
      return
    }
  }
}

一般是等待第一个协程结束或所有协程结束,如果多个协程的话可以计数。

sync里面有WaitGroup,也可以实现,等到sync的时候再说。

缓存模式

Go-并发模式1(Basic Examples)中提到了channel有buffer,但是Rob Pike在2012年的演讲中没有讲。

举个例子,假设厨师做饭一会儿做的快,可能是凉菜,一会儿做的慢,可能是佛跳墙。服务员的端菜速度是一定的,如果菜没有地方放,只能等待服务员拿的话,就会很慢,因为厨师做快了没有地方放(阻塞),做慢了的话服务员要一直等(阻塞)。

package main
import (
  "fmt"
  "math/rand"
  "time"
)
var food = make(chan string)
func cook(foods []string){
  for _,f := range foods{
    if f == "凉菜"{
      time.Sleep(100*time.Millisecond)
      food<-"凉菜"
    }else {
      time.Sleep(800*time.Millisecond)
      food<-"佛跳墙"
    }
  }
}
func server(finish chan bool){
  for {
    select {
    case name:=<-food:
      time.Sleep(time.Duration(rand.Intn(600))*time.Millisecond)
      fmt.Println("客官,上菜了:",name)
      finish<-true
    default:
      //fmt.Println("服务员在等待...")
    }
  }
}
func main() {
  foods := []string{"凉菜","凉菜","凉菜","凉菜","凉菜","凉菜","佛跳墙","凉菜"}
  n := len(foods)
  cnt := 0
  finish := make(chan bool)
  start := time.Now()
  go cook(foods)
  go server(finish)
  for{
    select {
    case <-finish:{
      cnt += 1
      if cnt == n{
        fmt.Println(time.Since(start))
        return
      }
    }
    }
  }
}

上面代码是没有缓存的,会慢一些,如果把food改为

var food = make(chan string,6)

就会快一些,结果如下:

2020062310470442.png

总结

添加goroutine进行并发后,程序发生了以下变化:

  1. 慢速->快速
  2. 顺序->并发
  3. 不健壮->健壮

参考

更多Go相关内容:Go-Golang学习总结笔记

有问题请下方评论,转载请注明出处,并附有原文链接,谢谢!如有侵权,请及时联系。




相关文章
|
10天前
|
Go 调度 开发者
探索Go语言中的并发模式:goroutine与channel
在本文中,我们将深入探讨Go语言中的核心并发特性——goroutine和channel。不同于传统的并发模型,Go语言的并发机制以其简洁性和高效性著称。本文将通过实际代码示例,展示如何利用goroutine实现轻量级的并发执行,以及如何通过channel安全地在goroutine之间传递数据。摘要部分将概述这些概念,并提示读者本文将提供哪些具体的技术洞见。
|
26天前
|
Java 大数据 Go
Go语言:高效并发的编程新星
【10月更文挑战第21】Go语言:高效并发的编程新星
47 7
|
21天前
|
并行计算 安全 Go
Go语言的并发特性
【10月更文挑战第26天】Go语言的并发特性
11 1
|
1月前
|
安全 Go 调度
探索Go语言的并发模式:协程与通道的协同作用
Go语言以其并发能力闻名于世,而协程(goroutine)和通道(channel)是实现并发的两大利器。本文将深入了解Go语言中协程的轻量级特性,探讨如何利用通道进行协程间的安全通信,并通过实际案例演示如何将这两者结合起来,构建高效且可靠的并发系统。
|
1月前
|
安全 Go 开发者
破译Go语言中的并发模式:从入门到精通
在这篇技术性文章中,我们将跳过常规的摘要模式,直接带你进入Go语言的并发世界。你将不会看到枯燥的介绍,而是一段代码的旅程,从Go的并发基础构建块(goroutine和channel)开始,到高级模式的实践应用,我们共同探索如何高效地使用Go来处理并发任务。准备好,让Go带你飞。
|
1月前
|
安全 Go 调度
探索Go语言的并发之美:goroutine与channel
在这个快节奏的技术时代,Go语言以其简洁的语法和强大的并发能力脱颖而出。本文将带你深入Go语言的并发机制,探索goroutine的轻量级特性和channel的同步通信能力,让你在高并发场景下也能游刃有余。
|
29天前
|
安全 程序员 Go
深入浅出Go语言的并发之道
在本文中,我们将探索Go语言如何优雅地处理并发编程。通过对比传统多线程模型,我们将揭示Go语言独特的goroutine和channel机制是如何简化并发编程,并提高程序的效率和稳定性。本文不涉及复杂的技术术语,而是用通俗易懂的语言,结合生动的比喻,让读者能够轻松理解Go语言并发编程的核心概念。
|
1月前
|
安全 Go 调度
探索Go语言的并发之美:goroutine与channel的实践指南
在本文中,我们将深入探讨Go语言的并发机制,特别是goroutine和channel的使用。通过实际的代码示例,我们将展示如何利用这些工具来构建高效、可扩展的并发程序。我们将讨论goroutine的轻量级特性,channel的同步通信能力,以及它们如何共同简化并发编程的复杂性。
|
1月前
|
安全 Go 数据处理
掌握Go语言并发:从goroutine到channel
在Go语言的世界中,goroutine和channel是构建高效并发程序的基石。本文将带你一探Go语言并发机制的奥秘,从基础的goroutine创建到channel的同步通信,让你在并发编程的道路上更进一步。
|
Go 微服务
一文搞懂如何实现 Go 超时控制
为什么需要超时控制? 请求时间过长,用户侧可能已经离开本页面了,服务端还在消耗资源处理,得到的结果没有意义。过长时间的服务端处理会占用过多资源,导致并发能力下降,甚至出现不可用事故。