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
|
/* test posix thread folder proxy */
#include "camel.h"
CamelThreadProxy *proxy;
CamelFuncDef *func_def;
void
test_sync_func (int num)
{
printf ("Sync function number %d\n", num);
printf ("Sync function : current thread : %d\n", pthread_self ());
}
void
test_async_cb (int num)
{
printf ("Callback number %d\n", num);
printf ("Callback : current thread : %d\n", pthread_self ());
}
void
test_async_func (int num)
{
CamelOp *cb;
printf ("Async function number %d\n", num);
printf ("Async function : current thread : %d\n", pthread_self ());
sleep (1);
cb = camel_marshal_create_op (func_def, test_async_cb, num);
camel_thread_proxy_push_cb (proxy, cb);
}
int
main (int argc, char **argv)
{
int i;
CamelOp *op;
camel_init ();
func_def =
camel_func_def_new (camel_marshal_NONE__INT,
1,
GTK_TYPE_INT);
printf ("--== Testing Simple marshalling system ==--\n");
for (i=0; i<5; i++) {
printf ("Iterration number %d\n", i);
op = camel_marshal_create_op (func_def, test_sync_func, i);
camel_op_run (op);
camel_op_free (op);
}
printf ("\n\n");
proxy = camel_thread_proxy_new ();
printf ("--== Testing Asynchronous Operation System ==--\n");
for (i=0; i<5; i++) {
printf ("Pushing async operation number %d for execution\n", i);
op = camel_marshal_create_op (func_def, test_async_func, i);
camel_thread_proxy_push_op (proxy, op);
}
printf ("\n\n");
printf ("--== Operations execution planned ==--\n");
gtk_main ();
}
|
