Sha256: 748839cc603d4d5b0cd1a6dfd7a9f359a1eb7b7cd1d17dca46b44395b7899da2
Contents?: true
Size: 779 Bytes
Versions: 2
Compression:
Stored size: 779 Bytes
Contents
#!/usr/bin/env ruby # Test thread safety require "test/unit" require "dbus" class ThreadSafetyTest < Test::Unit::TestCase def test_thread_competition print "Thread competition: " jobs = [] 5.times do jobs << Thread.new do Thread.current.abort_on_exception = true # use separate connections to avoid races bus = DBus::ASessionBus.new svc = bus.service("org.ruby.service") obj = svc.object("/org/ruby/MyInstance") obj.introspect obj.default_iface = "org.ruby.SampleInterface" 10.times do |i| print "#{i} " $stdout.flush assert_equal 42, obj.the_answer[0] sleep 0.1 * rand end end end jobs.each do |thread| thread.join end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
ruby-dbus-0.9.1 | test/thread_safety_test.rb |
ruby-dbus-0.9.0 | test/thread_safety_test.rb |