Sha256: cb56480c2156dac157f8e37901ca9cbedff6c538a2538e21506493e28a559185
Contents?: true
Size: 770 Bytes
Versions: 10
Compression:
Stored size: 770 Bytes
Contents
#!/usr/bin/env rspec
# frozen_string_literal: true
# Test thread safety
require_relative "spec_helper"
require "dbus"
describe "ThreadSafetyTest" do
it "tests thread competition" do
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.default_iface = "org.ruby.SampleInterface"
10.times do |i|
print "#{i} "
$stdout.flush
expect(obj.the_answer[0]).to eq(42)
sleep 0.1 * rand
end
end
end
jobs.each(&:join)
end
end
Version data entries
10 entries across 10 versions & 1 rubygems