11 Goroutine-并发与并行、阻塞与非阻塞

2024-05-28 09:44

本文主要是介绍11 Goroutine-并发与并行、阻塞与非阻塞,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

并发

顺序执行:按照事先计划好的顺序,执行完一个操作后,再执行下一个操作。

顺序执行效率不高的原因:

  • 每个操作由多个步骤组成,每个步骤所需要的时间长短不一,有些步骤可能相当耗时。
  • 顾客点菜需要时间,后厨做菜也需要时间,可否利用这些时间为更多顾客提供服务呢。

优化目标:减少不必要的闲置和等待,最大化处理机时间,提高工作效率

  • 当一个操作执行到某个相当耗时的步骤时,转而执行其它操作中相对不太耗时的步骤。
  • 待这些非耗时步骤完成后,之前那个耗时的步骤也完成了,再继续回到前一个操作中。

并发执行:没有固定的执行顺序,不等一个操作执行完,即开始下一个操作

并发与并行

并发一个行为主体同时执行多个操作。

并行多个行为主体同时执行多个操作。

浏览器中的并发

启用浏览器开发人员工具,打开任意可访问页面,可以看到浏览器并不是依次发出每一个请求,而是同时发出很多请求,以尽快渲染页面的每个组成部分。这样做的好处是页面的整体加载速度在用户看来非常之快。

阻塞与非阻塞

在实际编程中,有些函数的执行速度很,对于调用者而言几乎瞬间就返回了,这样的函数称为非阻塞函数。

但另一些函数的执行速度则可能非常缓,在调用者看来从调用到返回需要经历非常漫长的等待,甚至可能是永久的等待,这样的函数称为阻塞函数。

  • 在顺序模式中,阻塞的操作会导致其后的操作长期永远得不到执行,降低程序的性能。
  • 在并发模式中,阻塞的操作会和其它操作分属于不同的执行过程,快不必等慢,高性能。
// 顺序执行
// 在顺序模式中,阻塞的操作过程会导致其后的操作永远或长期得不到执行,降低程序的性能
package main
import ("fmt""time"
)
func proc(ch rune, ms time.Duration) {for {	// 死循环,模拟阻塞fmt.Printf("%c", ch)time.Sleep(ms * time.Millisecond)}
}
func main() {proc('-', 100)proc('+', 500)
}
// 打印输出:
// -------------------------

通过goroutine并发处理

Go语言通过Goroutine处理并发,为了使某个函数在独立的"线程"中执行,只需在调用该函数的时候使用关键字go。

  • go proc('-', 100)

将任何阻塞函数放在关键字go的后面执行:

  • 立即启动一个独立的"子线程",并在该"子线程"中执行阻塞函数中的代码。
  • 与此同时"父线程"从go中立即返回,并不等待阻塞函数返回,即"子线程"结束。
  • "父线程"在"子线程"执行阻塞函数的同时,执行该语句下面的操作。
  • go下面的操作和go后面的函数分别运行在父子两个独立"线程"中。
  • 阻塞函数执行完毕返回,"子线程"结束。
// 并发执行
// 在并发模式中,阻塞的操作过程运行于独立的"线程"之中,不会影响其它操作的执行,提高了程序的性能
package main
import ("fmt""time"
)
func proc(ch rune, ms time.Duration) {for {fmt.Printf("%c", ch)time.Sleep(ms * time.Millisecond)}
}
func main() {go proc('-', 100) // 每100ms,打印-proc('+', 500)		// 每500ms,打印+
}
// 打印输出:
// +-----+-----+-----+-----+ 

Goroutine与线程

Goroutine常被称作轻量级线程逻辑线程,它和真正的线程还是有区别的。

线程

Goroutine

调度

开销

线程由操作系统内核调度,每隔几毫秒,会有一个硬件时钟中断发送到CPU,CPU会调用一个调度器内核函数。该函数暂停当前正在运行的线程,把它的寄存器信息保存到内存中,查看线程列表并决定接下来运行哪一个线程,再从内存中恢复此线程的寄存器信息并执行之。这种线程调度需要一个完整的上下文切换,即保存一个线程的状态到内存,再从内存恢复另一个线程的状态,同时还要不断更新调度器的数据结构。某种意义上讲,这种操作还是相当耗时的。

Go语言程序运行时自带一个调度器,这个调度器使用一个称为一个M:N的调度技术,即将M个Goroutine调度到N个线程中,Go的调度器不由硬件时钟定期触发,而由特定的Go语言结构触发,也不需要在用户态和内核态之间来回切换,所以调度一个Goroutine比调度一个线程的开销要小得多。

栈空间

每个线程都有一个固定大小的栈内存,通常是2M字节,栈内存用于保存函数的参数、局部变量和返回地址。

Goroutine的栈内存是动态的,开始只有2K字节,而后随着程序的运行,再根据实际需要增大或缩小,最大可以到1G字节。

线程

标识

在大部分支持线程的操作系统中,每个线程都有一个唯一标识,通常是一个整数或者结构体,通过该标识可以为每个线程创建独立的全局存储空间,谓之线程局部存储。

Goroutine没有提供可被程序员访问的唯一标识,它是一种纯函数的理念。Go语言认为线程局部存储的滥用会导致一种不健康的超距作用,即函数的行为不仅取决于它的参数,还与执行它的线程有关。

这篇关于11 Goroutine-并发与并行、阻塞与非阻塞的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1010212

相关文章

高并发环境中保持幂等性

在高并发环境中保持幂等性是一项重要的挑战。幂等性指的是无论操作执行多少次,其效果都是相同的。确保操作的幂等性可以避免重复执行带来的副作用。以下是一些保持幂等性的常用方法: 唯一标识符: 请求唯一标识:在每次请求中引入唯一标识符(如 UUID 或者生成的唯一 ID),在处理请求时,系统可以检查这个标识符是否已经处理过,如果是,则忽略重复请求。幂等键(Idempotency Key):客户端在每次

Java并发编程之——BlockingQueue(队列)

一、什么是BlockingQueue BlockingQueue即阻塞队列,从阻塞这个词可以看出,在某些情况下对阻塞队列的访问可能会造成阻塞。被阻塞的情况主要有如下两种: 1. 当队列满了的时候进行入队列操作2. 当队列空了的时候进行出队列操作123 因此,当一个线程试图对一个已经满了的队列进行入队列操作时,它将会被阻塞,除非有另一个线程做了出队列操作;同样,当一个线程试图对一个空

springboot体会BIO(阻塞式IO)

使用springboot体会阻塞式IO 大致的思路为: 创建一个socket服务端,监听socket通道,并打印出socket通道中的内容。 创建两个socket客户端,向socket服务端写入消息。 1.创建服务端 public class RedisServer {public static void main(String[] args) throws IOException {

多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

目录 多路转接之select 引入 介绍 fd_set 函数原型 nfds readfds / writefds / exceptfds readfds  总结  fd_set操作接口  timeout timevalue 结构体 传入值 返回值 代码 注意点 -- 调用函数 select的参数填充  获取新连接 注意点 -- 通信时的调用函数 添加新fd到

java线程深度解析(五)——并发模型(生产者-消费者)

http://blog.csdn.net/Daybreak1209/article/details/51378055 三、生产者-消费者模式     在经典的多线程模式中,生产者-消费者为多线程间协作提供了良好的解决方案。基本原理是两类线程,即若干个生产者和若干个消费者,生产者负责提交用户请求任务(到内存缓冲区),消费者线程负责处理任务(从内存缓冲区中取任务进行处理),两类线程之

java线程深度解析(四)——并发模型(Master-Worker)

http://blog.csdn.net/daybreak1209/article/details/51372929 二、Master-worker ——分而治之      Master-worker常用的并行模式之一,核心思想是由两个进程协作工作,master负责接收和分配任务,worker负责处理任务,并把处理结果返回给Master进程,由Master进行汇总,返回给客

深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理

深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理 秒杀系统是应对高并发、高压力下的典型业务场景,涉及到并发控制、库存管理、事务管理等多个关键技术点。本文将深入剖析秒杀商品业务中常见的几个核心问题,包括 AOP 事务管理、同步锁机制、乐观锁、CAS 操作,以及用户限购策略。通过这些技术的结合,确保秒杀系统在高并发场景下的稳定性和一致性。 1. AOP 代理对象与事务管理 在秒杀商品

PostgreSQL中的多版本并发控制(MVCC)深入解析

引言 PostgreSQL作为一款强大的开源关系数据库管理系统,以其高性能、高可靠性和丰富的功能特性而广受欢迎。在并发控制方面,PostgreSQL采用了多版本并发控制(MVCC)机制,该机制为数据库提供了高效的数据访问和更新能力,同时保证了数据的一致性和隔离性。本文将深入解析PostgreSQL中的MVCC功能,探讨其工作原理、使用场景,并通过具体SQL示例来展示其在实际应用中的表现。 一、

使用协程实现高并发的I/O处理

文章目录 1. 协程简介1.1 什么是协程?1.2 协程的特点1.3 Python 中的协程 2. 协程的基本概念2.1 事件循环2.2 协程函数2.3 Future 对象 3. 使用协程实现高并发的 I/O 处理3.1 网络请求3.2 文件读写 4. 实际应用场景4.1 网络爬虫4.2 文件处理 5. 性能分析5.1 上下文切换开销5.2 I/O 等待时间 6. 最佳实践6.1 使用 as

Go并发模型:流水线模型

Go作为一个实用主义的编程语言,非常注重性能,在语言特性上天然支持并发,Go并发模型有多种模式,通过流水线模型系列文章,你会更好的使用Go的并发特性,提高的程序性能。 这篇文章主要介绍流水线模型的流水线概念,后面文章介绍流水线模型的FAN-IN和FAN-OUT,最后介绍下如何合理的关闭流水线的协程。 Golang的并发核心思路 Golang并发核心思路是关注数据流动。数据流动的过程交给cha