当前位置:

首页 > 编程开发 > ruby中并发并行与全局锁详解

ruby中并发并行与全局锁详解

Ruby全局锁(GIL)使多线程在CPU密集型任务中无法并行提速,但IO操作可并发切换。通过厨师比喻和代码示例,阐释了顺序执行与多线程的差异,强调并发不等于并行。

Ruby 的并发与并行,以及那个让无数开发者又爱又恨的全局锁(GIL),是每个 Ruby 程序员进阶路上绕不开的话题。很多初学者会困惑:为什么我开了多线程,计算速度却没提升?为什么 IO 操作时又能“并行”?这篇文章就来把这些概念掰开揉碎,结合代码实例,把底层逻辑讲清楚。

并发和并行

开发中常遇到两个概念:并发和并行。几乎所有相关文章都会强调一点:并发不等于并行。怎么理解呢?

  • 并发:厨师同时收到了两位客人的菜单需要处理。
  • 顺序执行:如果只有一个厨师,他只能一个接一个地完成菜单。
  • 并行执行:如果有两个厨师,就可以同时做菜,互不影响。

把这个场景迁移到 Web 开发中:

  • 并发:服务器同时收到了两个客户端发起的请求。
  • 顺序执行:服务器只有一个进程(或线程)处理请求,做完第一个才能做第二个,第二个请求只能等待。
  • 并行执行:服务器有两个进程(或线程)处理请求,两个请求都能得到响应,不存在先后问题。

在 Ruby 里怎么模拟并发行为?来看代码:

1、顺序执行
模拟只有一个线程时的操作。

require 'benchmark'

def f1
 puts "sleep 3 seconds in f1n"
 sleep 3
end

def f2
 puts "sleep 2 seconds in f2n"
 sleep 2 
end

Benchmark.bm do |b|
 b.report do
 f1
 f2
 end 
end
## 
## user  system  total  real
## sleep 3 seconds in f1
## sleep 2 seconds in f2
## 0.000000 0.000000 0.000000 ( 5.009620)

用 sleep 模拟耗时操作,顺序执行时总耗时就是两个函数耗时之和。

2、并行执行
模拟多线程时的操作。

# 接上述代码
Benchmark.bm do |b|
 b.report do
 threads = []
 threads << Thread.new { f1 }
 threads << Thread.new { f2 }
 threads.each(&:join)
 end 
end
##
## user  system  total  real
## sleep 3 seconds in f1
## sleep 2 seconds in f2
## 0.000000 0.000000 0.000000 ( 3.005115)

多线程下耗时接近 f1 的耗时(3 秒),这正是我们期望的“并行”——两个线程同时睡眠,整体时间由最长的那个决定。Ruby 的多线程能够很好地应付 IO Block:当某个线程处于 IO 阻塞状态时,其他线程可以继续执行,从而大幅缩短整体处理时间。

Ruby 中的线程

上面的代码用到了 Ruby 内置的 Thread 类。Ruby 的线程是轻量级的,写起来也相当直观。

再看一个模拟并发的例子:

def thread_test
 time = Time.now
 threads = 3.times.map do 
  Thread.new do
  sleep 3 
  end
 end
 puts "不用等3秒就可以看到我:#{Time.now - time}"
 threads.map(&:join)
 puts "现在需要等3秒才可以看到我:#{Time.now - time}"
end
test
## 不用等3秒就可以看到我:8.6e-05
## 现在需要等3秒才可以看到我:3.003699

Thread 的创建是非阻塞的,所以第一个 puts 会立即输出,随后通过 join 等待所有线程结束。每个线程 sleep 3 秒,在阻塞的场景下,多线程确实实现了类似并行的效果。

但,是不是有了多线程就能真正利用多核 CPU 并行计算了呢?

很遗憾,下面的例子会打破这个幻想:

require 'benchmark'
def multiple_threads
 count = 0
 threads = 4.times.map do 
 Thread.new do
  2500000.times { count += 1}
 end
 end
 threads.map(&:join)
end

def single_threads
 time = Time.now
 count = 0
 Thread.new do
 10000000.times { count += 1}
 end.join
end

Benchmark.bm do |b|
 b.report { multiple_threads }
 b.report { single_threads }
end
##  user  system  total  real
## 0.600000 0.010000 0.610000 ( 0.607230)
## 0.610000 0.000000 0.610000 ( 0.623237)

即使是把同一个任务拆成 4 个线程“并行”执行,总耗时居然和单线程差不多少!为什么?

因为全局锁(GIL)的存在。

全局锁

我们常用的 MRI Ruby 实现中有一个 GIL(Global Interpreter Lock)。简单说,即便你开了多线程,每次也只能有一个线程真正执行 Ruby 代码。至于哪个线程能执行,由底层操作系统调度决定。即便你有多个 CPU,也只是为线程切换提供了更多选择,并不能同时执行多条 Ruby 指令。

上面的 count += 1 就是纯 Ruby 运算,受 GIL 限制,无法并行,所以时间不缩短,甚至因为线程切换还略有增加。

可是等等,之前 sleep 和网络请求的例子明明是“并行”的啊!

这正是 Ruby 设计的高明之处:所有阻塞操作(IO 操作)在 GIL 下是可以并行的。比如读写文件、网络请求,当某个线程陷入 IO 等待时,GIL 会被释放,其他线程就能趁机执行。这才是多线程的真正优势——不是加快计算,而是提高 IO 密集型任务的吞吐量。

下面用网络请求验证:

require 'benchmark'
require 'net/http'

# 模拟网络请求
def multiple_threads
 uri = URI("http://www.baidu.com")
 threads = 4.times.map do 
 Thread.new do
  25.times { Net::HTTP.get(uri) }
 end
 end
 threads.map(&:join)
end

def single_threads
 uri = URI("http://www.baidu.com")
 Thread.new do
 100.times { Net::HTTP.get(uri) }
 end.join
end

Benchmark.bm do |b|
 b.report { multiple_threads }
 b.report { single_threads }
end

 user  system  total  real
0.240000 0.110000 0.350000 ( 3.659640)
0.270000 0.120000 0.390000 ( 14.167703)

网络请求时 CPU 基本空闲,线程处于 IO 阻塞状态,这时 GIL 被释放,多个线程可以同时发起请求,耗时从 14 秒降到了 3.6 秒。

GIL 的思考

那么,有了 GIL 是不是就线程安全了呢?

当然不是。GIL 只保证一次只有一个线程执行 Ruby 代码,但 Ruby 解释器在执行过程中会在某些 “检查点” 切换到另一个线程。如果共享了类变量或全局变量,就可能踩坑。

哪些地方会触发 GIL 切换?

  • 方法的调用和返回:这两个点都会检查当前线程的 GIL 锁是否超时,是否需要调度到其他线程。
  • 所有 IO 相关操作:会释放 GIL 锁让其他线程工作。
  • C 扩展代码中手动释放 GIL 锁。
  • Ruby stack 进入 C stack 时也会触发 GIL 检测(这个稍微难理解一些)。

来看一个实际的竞争例子。先看一个 没有触发 GIL 切换 的代码:

@a = 1
r = []
10.times do |e|

Thread.new {
 @c = 1
 @c += @a
 r << [e, @c]
}
end
r
## [[3, 2], [1, 2], [2, 2], [0, 2], [5, 2], [6, 2], [7, 2], [8, 2], [9, 2], [4, 2]]

这里每个线程的 @c 都能正确保持为 2,没有出现数据错乱。

但如果在线程里加入一个可能触发 GIL 切换的操作,比如 puts:

@a = 1
r = []
10.times do |e|

Thread.new {
 @c = 1
 puts @c
 @c += @a
 r << [e, @c]
}
end
r
## [[2, 2], [0, 2], [4, 3], [5, 4], [7, 5], [9, 6], [1, 7], [3, 8], [6, 9], [8, 10]]

这次,GIL 被触发切换,各个线程的调度顺序被打乱,共享变量 @c 出现了竞争,最终结果就不对了。

小结

Web 应用大多是 IO 密集型的,利用 Ruby 多进程+多线程模型能大幅提升系统吞吐量。根本原因在于:当某个线程处于 IO Block 状态时,其他线程可以继续执行,从而降低 IO 阻塞对整体的影响。但由于 GIL 的存在,MRI Ruby 并不能真正利用多线程进行并行计算——纯 CPU 运算在多线程下并不会更快。

另外,据说 JRuby 去除了 GIL,是真正意义上的多线程,既能应付 IO Block,也能充分利用多核 CPU 加快运算速度,有兴趣的话可以了解一下。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
作者最新文章
编程开发
相关文章 更多
Ruby日期时间的比较,日期转换等时间日期处理方法大全
Ruby日期时间的比较,日期转换等时间日期处理方法大全

Ruby日期时间处理主要依赖Date、Time和DateTime三个类。Date仅处理日期,Time可处理日期时间,DateTime是Date子类且效率最高。三者支持创建、字符串转换、比较、加减、时区处理及类型互转。Date与DateTime严格校验无效日期,Time则自动进位。常用操作包括构建、解析、格式化及与数值转换。

Ruby信号处理详解
Ruby信号处理详解

Ruby中Process.kill方法发送信号,signal参数可为整数或符号名指定信号类型,pid参数为正数时发送给指定进程,为0时发送给同组所有进程,为负数时发送给对应进程组(绝对值)。

深入分析Ruby 变量
深入分析Ruby 变量

Ruby变量以命名前缀区分五种类型:全局变量($)可跨类访问但副作用大;实例变量(@)为对象私有数据;类变量(@@)在继承链共享;局部变量(小写/下划线)作用域受限;常量(大写)不可重赋值。伪变量如self、nil不可修改。未初始化变量通常为nil,常量赋值会触发警告。

Rails实现字段加密存储
Rails实现字段加密存储

在Rails中,利用ActiveSupport::MessageEncryptor实现字段加密,结合ActiveRecord的serialize机制定义自定义Serializer,使敏感字段存入时自动加密、读取时自动解密,业务层无需关注加密细节。同时需注意密钥安全管理和旧数据的平滑迁移。

ruby on rails中Model的关联详解
ruby on rails中Model的关联详解

Rails中Model关联需在两端声明,遵循命名惯例:belongs_to后跟单数,has_many后跟复数。一对多通过外键实现,如妈妈与儿子;多对多借助中间表,如学生与老师通过课程表关联。掌握这些基础可高效处理复杂关联。

使用RVM实现控制切换Ruby/Rails版本
使用RVM实现控制切换Ruby/Rails版本

RVM能自由切换Ruby与Rails版本,避免反复重装。通过rvminstall安装指定Ruby版本,用rvmlist查看已安装版本,切换并设为默认。创建gemset绑定Ruby版本,再安装不同Rails版本,即可灵活切换,实现多项目环境隔离。

Ruby 中的 module
Ruby 中的 module

module_function将模块的实例方法复制到单例类,原方法变为私有,仅能通过模块名调用。extendself不改变可见性,public方法既可通过模块名也可通过实例调用。两者均用于暴露模块级方法,但权限不同。

Ruby是什么以及如何使用
Ruby是什么以及如何使用

Ruby是松本行弘于1993年创造的纯面向对象动态语言,融合Smalltalk、Perl和Python精髓,语法简洁易读,一切皆对象。开源解释型跨平台,适合Web开发和脚本编写,可扩展性强,支持多种数据库及GUI工具,是RubyonRails框架的核心语言之一。

Ruby on rails安装后去掉DL is deprecated,please use Fiddle警告信息的方法【测试可用】
Ruby on rails安装后去掉DL is deprecated,please use Fiddle警告信息的方法【测试可用】

在RubyonRails框架中,安装后执行命令时常会出现“DLisdeprecated,pleaseuseFiddle”警告。具体解决方法如下:首先找到Ruby安装目录下的lib/ruby/2.1.0文件夹,进入后找到其中的dl.rb文件,使用文本编辑器打开该文件,定位到含有warn的那一行,在行首添加井号#注释掉该行,保存文件后警告立即消失。

ruby 正则表达式详解及示例代码
ruby 正则表达式详解及示例代码

Ruby正则表达式常用语法包括重复次数(*+?)、范围描述符([])、字符类(如\d\w\s)、边界匹配(^$)、分组捕获及转义等元字符,提供非负整数、邮箱、账号等典型匹配模式,广泛用于表单验证与文本处理,便于快速查阅与套用,功能强大。

查看更多
精品专题 更多
装机必备
装机必备

正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

Windows
Windows

正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

PDF教程
PDF教程

正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

Mac软件 更多
Adobe Acrobat Pro macOS版
Adobe Acrobat Pro macOS版
Mac

Adobe Acrobat Pro 是面向办公、法务、财务、教育及出版用户的专业PDF处理软件,可在Mac上创建、编辑、转换、合并和保护文档,并提供OCR文字识别、表单、批注、内容比较、敏感信息遮盖及电子签名功能。

Blender
Blender
Windows、macOS 和 Linux

Blender 是一款免费开源、跨平台的专业 3D 创作软件,集建模、动画、渲染、视频编辑与视觉合成等功能于一体,广泛应用于影视动画、游戏设计和建筑可视化等领域。软件支持 Cycles 物理渲染器与 Eevee 实时渲染引擎,并提供多边形建模、骨骼绑定、物理模拟等专业工具。Blender 兼容 Windows、macOS 和 Linux 系统,安装包轻巧、运行流畅,依托活跃的全球开发者社区持续更新,是从初学者到专业创作者都值得选择的正版 3D 创作工具。

Shapr3D macOS版
Shapr3D macOS版
Mac

Shapr3D是一款面向工业设计、机械工程、建筑概念和三维打印工作流的CAD软件。Mac版采用Parasolid建模内核,支持草图约束、实体建模、工程图、可视化渲染及常见CAD格式交换,并可通过账户在多台设备之间同步项目。

WINDOWS 更多
3ds max(3dmax)
3ds max(3dmax)
Windows

Autodesk 3ds Max 是一款专业的三维建模、动画与渲染软件,广泛应用于建筑可视化、游戏开发、影视动画、广告设计和产品展示等领域。

PixTV 网页版
PixTV 网页版
Windows

PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。

AutoCAD Windows版
AutoCAD Windows版
Windows

AutoCAD 是 Autodesk 推出的专业计算机辅助设计软件,Windows 版支持精确二维绘图、三维实体与曲面建模、图纸标注、布局发布和任务自动化,并包含多套行业专业化工具组合,适用于建筑、机械、电气、工程建设及制造设计人员。