Tag: 多

Ruby：等待使用join和ThreadsWait.all_waits完成的所有线程 – 有什么区别？: 请考虑以下示例： threads = [] (0..10).each do |_| threads << Thread.new do #do async staff there sleep Random.rand(10) end end 然后有2种方法可以在完成后等待：使用join： threads.each(&:join) 使用ThreadsWait ： ThreadsWait.all_waits(threads) 这两种方式之间有什么区别吗？我知道ThreadsWait类有其他有用的方法。并特别询问all_waits方法。

具有活动记录的rails控制台中的线程在数据库中找不到Model: 我正在使用Rails 3和Ruby 1.9。我在各种rails测试中（以及在控制台中）运行了2种方法。这些方法称为index_cases和index_new_cases ，方法体如下所示。 index_new_cases方法的内容可能不相关（我使用Sunspot gem索引ModelCase信息），但为了完整性我将其保留在那里。我有3个case_numbers 。每个case_number匹配数据库中的ModelCase （即db中有3个ModelCase记录）。当我使用这3个case_numbers对index_cases方法运行测试时， index_new_cases方法不会使用ModelCase.where…方法检索任何情况。但是，如果我删除index_cases方法中的“线程”调用， index_new_cases函数现在检索所有3个案例并正确索引它们。任何人都可以向我解释为什么我的线程找不到数据库记录？我的线程实现是错误的吗？谢谢！ def index_cases(case_numbers) threads = [] case_numbers.each_slice(500) do |slice_of_case_numbers| threads << Thread.new(slice_of_case_numbers) do |a_slice| index_new_cases(a_slice) end end threads.each {|thr| thr.join} end def index_new_cases(case_numbers) cs = ModelCase.where(case_number: case_numbers).includes(:child_tables) puts cs.size # prints 0 with threading and 3 without […]

为什么Ruby中的数组操作不是primefaces的？: 在Ruby中，如果array被许multithreading修改，则此代码不是线程安全的： array = [] array << :foo # many threads can run this code 为什么<<操作不是线程安全的？

在Ruby中实现同步障碍: 我试图在Ruby中“复制”CUDA的__synchtreads()函数的行为。具体来说，我有一组需要执行某些代码的N线程，然后所有代码在执行中的中间点等待，然后继续执行其余的业务。例如： x = 0 a = Thread.new do x = 1 syncthreads() end b = Thread.new do syncthreads() # x should have been changed raise if x == 0 end [a,b].each { |t| t.join } 我需要使用哪些工具来完成此任务？我尝试使用全局哈希，然后hibernate，直到所有线程都设置了一个标志，表明他们已完成代码的第一部分。我无法让它正常工作; 它导致了挂起和死锁。我想我需要使用Mutex和ConditionVariable的组合，但我不确定为什么/如何。编辑： 50次观看，无人接听！看起来像赏金的候选人……

Ruby线程和变量: 为什么结果不是1到10，而只是10s？ require ‘thread’ def run(i) puts i end while true for i in 0..10 Thread.new{ run(i)} end sleep(100) end 结果： 10 10 10 10 10 10 10 10 10 10 10 为什么循环？我正在循环运行，因为后来我想一直遍历数据库表并回显从数据库中检索到的任何记录。