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

相关文章

Web服务器-Nginx-高并发问题

《Web服务器-Nginx-高并发问题》Nginx通过事件驱动、I/O多路复用和异步非阻塞技术高效处理高并发,结合动静分离和限流策略,提升性能与稳定性... 目录前言一、架构1. 原生多进程架构2. 事件驱动模型3. IO多路复用4. 异步非阻塞 I/O5. Nginx高并发配置实战二、动静分离1. 职责2

Java Stream 并行流简介、使用与注意事项小结

《JavaStream并行流简介、使用与注意事项小结》Java8并行流基于StreamAPI,利用多核CPU提升计算密集型任务效率,但需注意线程安全、顺序不确定及线程池管理,可通过自定义线程池与C... 目录1. 并行流简介​特点:​2. 并行流的简单使用​示例:并行流的基本使用​3. 配合自定义线程池​示

从原理到实战解析Java Stream 的并行流性能优化

《从原理到实战解析JavaStream的并行流性能优化》本文给大家介绍JavaStream的并行流性能优化:从原理到实战的全攻略,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的... 目录一、并行流的核心原理与适用场景二、性能优化的核心策略1. 合理设置并行度:打破默认阈值2. 避免装箱

Spring Security 前后端分离场景下的会话并发管理

《SpringSecurity前后端分离场景下的会话并发管理》本文介绍了在前后端分离架构下实现SpringSecurity会话并发管理的问题,传统Web开发中只需简单配置sessionManage... 目录背景分析传统 web 开发中的 sessionManagement 入口ConcurrentSess

MyBatis的xml中字符串类型判空与非字符串类型判空处理方式(最新整理)

《MyBatis的xml中字符串类型判空与非字符串类型判空处理方式(最新整理)》本文给大家介绍MyBatis的xml中字符串类型判空与非字符串类型判空处理方式,本文给大家介绍的非常详细,对大家的学习或... 目录完整 Hutool 写法版本对比优化为什么status变成Long?为什么 price 没事?怎

MySQL中处理数据的并发一致性的实现示例

《MySQL中处理数据的并发一致性的实现示例》在MySQL中处理数据的并发一致性是确保多个用户或应用程序同时访问和修改数据库时,不会导致数据冲突、数据丢失或数据不一致,MySQL通过事务和锁机制来管理... 目录一、事务(Transactions)1. 事务控制语句二、锁(Locks)1. 锁类型2. 锁粒

深入解析Java NIO在高并发场景下的性能优化实践指南

《深入解析JavaNIO在高并发场景下的性能优化实践指南》随着互联网业务不断演进,对高并发、低延时网络服务的需求日益增长,本文将深入解析JavaNIO在高并发场景下的性能优化方法,希望对大家有所帮助... 目录简介一、技术背景与应用场景二、核心原理深入分析2.1 Selector多路复用2.2 Buffer

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

java如何实现高并发场景下三级缓存的数据一致性

《java如何实现高并发场景下三级缓存的数据一致性》这篇文章主要为大家详细介绍了java如何实现高并发场景下三级缓存的数据一致性,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 下面代码是一个使用Java和Redisson实现的三级缓存服务,主要功能包括:1.缓存结构:本地缓存:使