Ticket #542: testThreadComm.rb

require 'thread.rb'

class TestLayoutList
   def initialize
      @mutex = Mutex.new
      @ary = Array.new
   end

   def list
      @mutex.lock
      val = @ary.compact
      @mutex.unlock
      val
   end

   def add(item)
      @mutex.lock
      @ary.push(item)
      @mutex.unlock
   end

   def clear
      @mutex.lock
      @ary.clear
      @mutex.unlock
   end
end

layoutList = TestLayoutList.new

t1 = Thread.new {
   numValues = layoutList.list.length
   while (numValues < 10000000)
      p numValues
      sleep 1
      numValues = layoutList.list.length
   end
}

t2 = Thread.new {
   (0..10000000).each { |num|
      layoutList.add(num)
      #sleep 1
   }
}

t2.join
t1.kill