如何在 Ruby 中使用互斥体：综合指南-js教程-PHP中文网

如何在 Ruby 中使用互斥体：综合指南

WBOY

发布： 2024-08-22 18:44:39

原创

630 人浏览过

How to Use Mutex in Ruby: A Comprehensive Guide

介绍

并发是编程中的一个强大工具，它使多个线程能够同时执行代码。然而，这种权力也伴随着安全管理共享资源的责任。在 Ruby 中，Mutex（互斥的缩写）是确保一次只有一个线程可以访问资源、防止潜在的数据损坏或不可预测的行为的关键组件。
在这篇博客中，我们将探讨如何在 Ruby 中使用 Mutex，并通过示例代码和现实场景来说明其实际应用。

什么是互斥锁？

互斥体是用于管理线程同步的对象。当一个线程锁定互斥锁时，任何其他尝试锁定同一互斥锁的线程都将被搁置，直到第一个线程释放它。这一机制确保访问共享资源的关键代码部分一次仅由一个线程执行。

为什么要使用互斥体？

想象一个场景，多个线程正在修改同一个变量或写入同一个文件。如果没有适当的同步，结果可能是不可预测的或不正确的。互斥体通过确保在任何给定时间只有一个线程可以访问共享资源来帮助避免此类问题。

如何在 Ruby 中使用互斥体

require 'thread'

# Initialize a Mutex
mutex = Mutex.new

# Shared resource
counter = 0

# Create threads
threads = 10.times.map do
  Thread.new do
    1000.times do
      # Lock the mutex before modifying the shared resource
      mutex.synchronize do
        counter += 1
      end
    end
  end
end

# Wait for all threads to finish
threads.each(&:join)

puts "Final counter value: #{counter}"

登录后复制

在此示例中：

我们初始化一个互斥对象。
我们创建一个将由多个线程访问的共享资源（计数器）。
我们创建 10 个线程，每个线程将计数器递增 1000 次。
在 mutex.synchronize 块内，我们确保一次只有一个线程可以修改计数器。
最后，我们打印计数器的最终值，如果互斥锁已正确同步访问，则该值应为 10000。

现实场景：管理银行账户交易

为了了解 Mutex 的实际应用，让我们考虑一个场景，其中多个线程代表银行帐户上的交易。每笔交易都可能涉及存款或取款，我们必须确保账户余额保持准确。

require 'thread'

# Initialize a Mutex
account_mutex = Mutex.new

# Bank account class
class BankAccount
  attr_reader :balance

  def initialize(balance = 0)
    @balance = balance
  end

  def deposit(amount)
    @balance += amount
  end

  def withdraw(amount)
    @balance -= amount
  end
end

# Shared bank account
account = BankAccount.new(1000)

# Transactions
threads = []

# Deposit thread
threads << Thread.new do
  100.times do
    account_mutex.synchronize do
      account.deposit(50)
    end
  end
end

# Withdraw thread
threads << Thread.new do
  100.times do
    account_mutex.synchronize do
      account.withdraw(30)
    end
  end
end

# Wait for all threads to finish
threads.each(&:join)

puts "Final account balance: #{account.balance}"

登录后复制