Example: Conditions
public class Context : Object {
private Cond data_cond = Cond ();
private Mutex data_mutex = Mutex ();
private string current_data = null;
private void push_data (string data) {
print ("=> push_data: lock\n");
data_mutex.lock ();
print ("=> push_data: set data\n");
current_data = data;
data_cond.signal ();
print ("=> push_data: unlock\n");
data_mutex.unlock ();
}
private string pop_data () {
print ("<= pop_data: lock\n");
data_mutex.lock ();
while (current_data == null) {
data_cond.wait (data_mutex);
}
print ("<= pop_data: get data\n");
string data = (owned) current_data;
print ("<= pop_data: unlock\n");
data_mutex.unlock ();
return data;
}
public void run () {
Thread<bool> thread2 = new Thread<bool> ("pop-data", () => {
print ("Thread start:\n");
this.pop_data ();
return true;
});
Thread.usleep (1000000);
this.push_data ("data");
thread2.join ();
// Possible output:
// ``<= pop_data: lock``
// ``=> push_data: lock``
// ``=> push_data: set data``
// ``=> push_data: unlock``
// ``<= pop_data: get data``
// ``<= pop_data: unlock``
}
public static int main (string[] args) {
Context context = new Context ();
context.run ();
return 0;
}
}
valac --target-glib 2.32 --pkg glib-2.0 GLib.Cond.vala
See:
