1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
#!/usr/bin/env ruby
=begin
threads.rb - Ruby/GTK sample script.
Copyright (c) 2003-2015 Ruby-GNOME2 Project Team
This program is licenced under the same licence as Ruby-GNOME2.
=end
require "gtk3"
require "thread"
class GtkJobQueue
def initialize
@queue = Queue.new
@worker_id = nil
end
def push(&job)
@queue << job
if @worker_id.nil?
start_worker
end
end
def stop
return if @worker_id.nil?
GLib::Source.remove(@worker_id)
@worker_id = nil
end
private
def start_worker
@worker_id = GLib::Idle.add do
job = @queue.pop
job.call
if @queue.empty?
@worker_id = nil
GLib::Source::REMOVE
else
GLib::Source::CONTINUE
end
end
end
end
job_queue = GtkJobQueue.new
label = Gtk::Label.new
Thread.new do
(0...1000).each do |cnt|
p "A:" + cnt.to_s
job_queue.push do
label.label = "A:" + cnt.to_s
end
sleep(2)
end
end
start_button = Gtk::Button.new(:label => "start")
stop_button = Gtk::Button.new(:label => "stop")
start_button.signal_connect("clicked") do
start_button.sensitive = false
@th = Thread.new do
(0...10).each do |cnt|
p "B:" + cnt.to_s
job_queue.push do
label.label = "B:" + cnt.to_s
end
sleep(2)
end
@th = nil
job_queue.push do
start_button.sensitive = true
start_button.grab_focus
stop_button.sensitive = false
end
end
stop_button.sensitive = true
stop_button.grab_focus
end
stop_button.signal_connect("clicked") do
if @th
@th.kill
puts "killed"
@th = nil
start_button.sensitive = true
start_button.grab_focus
stop_button.sensitive = false
end
end
stop_button.sensitive = false
box = Gtk::Box.new(:vertical, 0)
box.set_size_request(100, 100)
box << label << start_button << stop_button
win = Gtk::Window.new << box
win.show_all.signal_connect("delete_event") do
p "Exiting..."
job_queue.stop
Gtk.main_quit
Thread.list.each { |t| t.kill if t != Thread.main }
end
Gtk.main
|
