Ruby多线程编程

线程表示轻量级的子进程。 它是一个单独的执行路径。 在Ruby中，程序的不同部分可以通过使用多个进程在不同程序之间使用多个线程执行，或拆分程序中的任务来同时运行。

Ruby中的线程是并发编程模型的实现。

Ruby多线程

一般情况下，一个正常的程序的执行路径是单线执行。 按编码的顺序执行程序中的所有语句。
但是在多线程程序中，可以按多个路径多个执行程序。 多线程使用较少的内存空间并共享相同的地址空间。 多线程用于一次执行多个任务。

使用thread.new调用创建一个新线程。它与主线程的执行不同。

线程初始化

要创建一个新的线程Ruby提供了三个关键字，即::new，::start和::fork。

要启动新线程，请将一个代码块调用Thread.new，Thread.start或Thread.fork相关联。这样线程将被创建，新的线程在块退出时退出。

语法：

# Original thread runs  
Thread.new {  
  # New thread is created.  
}  
# Original thread runs

线程终止

在Ruby中终止一个线程有不同的方法。 要退出给定的线程，使用类名 ::kill 方法。

语法：

thr = Thread.new { ... }  
Thread.kill(thr)

Ruby线程实例

#!/usr/bin/ruby
# file : thread-example.rb

th = Thread.new do #Here we start a new thread   
  Thread.current['counter']=0   
  5.times do |i| #loop starts and increases i each time   
    Thread.current['counter']=i   
    sleep 1   
  end   
  return nil   
end   
while th['counter'].to_i < 4  do   
=begin   
th is the long running thread   
and we can access the same variable   
from inside the thread here   
=end   
  puts "Counter is #{th['counter']}"   
  sleep 0.5   
end   
puts "Long running process finished!"

执行上面代码，输出以下结果 -

F:\worksp\ruby>ruby thread-example.rb
Counter is
Counter is 0
Counter is 1
Counter is 1
Counter is 2
Counter is 2
Counter is 3
Counter is 3
Long running process finished!

F:\worksp\ruby>

线程生命周期

线程创建完成后，无需启动线程。 它获得正确的CPU资源后自动运行。 块中的最后一个表达式是线程的值。 如果线程完全运行，则value方法返回线程值，否则，value方法阻塞，并在线程完成时返回。 线程类在运行查询和操作线程时定义了一些方法。

通过调用线程的Thread.join方法，可以等待一个特定的线程完成。

线程异常处理

线程可能也会有一些异常。异常发生在主线程以外的任何线程中，但这取决于abort_on_exception。 默认情况下，此选项始终为false。表示未处理的异常将静默地终止线程。 这可以通过将abort_on_exception = true或$DEBUG设置为true来更改。

要处理异常，可以使用类的::handle_interrupt方法。 它将使用线程异步处理异常。

线程变量和范围

在块上创建线程。 在块内创建的局部变量仅可在该块存在的线程中访问。

Ruby线程类允许通过名称创建和访问线程局部变量。 线程对象像哈希一样处理，使用[]=写入元素，并使用[]读取它们。

线程调度

Ruby支持通过在程序中使用::stop和::pass方法调度线程。

类的::stop方法将当前正在运行的线程置于休眠状态并调度另一个线程的执行。 一旦线程处于休眠状态，实例方法唤醒被用来标记线程符合调度条件。

类的::pass方法尝试将执行传递给另一个线程。 这取决于操作系统运行的线程是否切换。

线程优先级提供了根据优先级调度线程的操作。 高优先级线程首先安排执行。 它也取决于操作系统。 线程可以随着第一个动作增加或减少自己的优先级。

线程排除

Ruby线程排除的状态，当两个线程共享相同的数据并且其中一个线程修改该数据时，需要确保在没有线程操作数据处于不一致的状态。 例如，银行服务器。 一个线程在账户中进行汇款，其他线程正在为客户生成月度报表。

公共类方法

公共实例方法