0

私はルビーが初めてで、スレッドを使いたいです。目的として、スレッドにスレッドを生成させたいのですが、以下のコードがあります:

require 'thread'
semaphore = Mutex.new

thr = Array.new
outputs = Array.new
scripts = Array.new
for i in 1..3
  thr[i] = Thread.new do
      puts "adding #{i} thread\n"
      puts "ready to create #{i} thread\n"
      scripts[i]= Thread.new do
        puts "in #{i} thread\n"
        puts "X#{i}\n"
        outputs[i] = "a#{i}" 
      end
  end 
end
for i in 1..3
  thr[i].join
end
for i in 1..3
  scripts[i].join
end
for i in 1..3
  puts outputs[i]
end

出力は

adding 1 thread
adding 2 thread
adding 3 thread
ready to create 3 thread
ready to create 1 thread
ready to create 1 thread
in 1 thread
in 1 thread
in 2 thread
X2
X3
X1
C:/Users/user/workspace/ruby-test/test.rb:61: undefined method `join' for nil:NilClass (NoMethodError)
    from C:/Users/liux14/workspace/ruby-test/test.rb:60:in `each'
    from C:/Users/liux14/workspace/ruby-test/test.rb:60

最初の 3 行は正しいのですが、次の i がめちゃくちゃです。

2 つの i = 1 と 1 つの i = 2 と 1 つの i = 3. そして、output[i] の 1 つは nil です。

私が逃したものは何ですか?

4

1 に答える 1

1

for i in 1..3ステートメントを使用するiと、 for ブロックの外で使用できるようになり、親スレッドと子スレッドで共有されるようになります。

代わりにブロックで試してください:

(1..3).each do |i|
  # code
end

#!/usr/bin/env ruby

require 'thread'
semaphore = Mutex.new

thr = Array.new
outputs = Array.new
scripts = Array.new
(1..3).each do |i|
  thr[i] = Thread.new do
      puts "adding #{i} thread\n"
      puts "ready to create #{i} thread\n"
      scripts[i]= Thread.new do
        puts "in #{i} thread\n"
        puts "X#{i}\n"
        outputs[i] = "a#{i}" 
      end
  end 
end
(1..3).each do |i|
  thr[i].join
end
(1..3).each do |i|
  scripts[i].join
end
(1..3).each do |i|
  puts outputs[i]
end

denis@DB:~/wk $ ./test.rb 
adding 1 thread
ready to create 1 thread
adding 3 thread
ready to create 3 thread
adding 2 thread
ready to create 2 thread
in 1 thread
X1
in 3 thread
in 2 thread
X3
X2
a1
a2
a3
于 2013-11-07T13:09:16.447 に答える