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
|
/*
* Copyright (C) 2018 Vito Caputo - <vcaputo@pengaru.com>
*
* This program is free software: you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 3 as published
* by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include <pulp.h>
#include <stdio.h>
#include <thunk.h>
THUNK_DEFINE(bye, pulp_t *, p)
{
/* note this is just to illustrate (and test) forced exit from a fiber,
* it's unnecessary if all fibers return, which has the same result.
*/
puts("bye!");
pulp_exit(p);
return 0;
}
THUNK_DEFINE(bar, int, id)
{
printf("%i ", id);
return 0;
}
THUNK_DEFINE(foo, pulp_t *, p, int, w, int, h)
{
for (int y = 0; y < h; y++) {
printf("\nw=%i h=%i\n", w, h);
for (int x = 0; x < w; x++)
(void) pulp_fiber_new(p, (w - x), THUNK(bar(x)));
pulp_msleep(p, w + 1, NULL);
}
(void) pulp_fiber_new(p, 0, THUNK(bye(p)));
pulp_msleep(p, 9999, NULL);
return 0;
}
int main(int argc, char *argv[])
{
pulp_t *p;
p = pulp_new();
(void) pulp_fiber_new(p, 0, THUNK(foo(p, 40, 100)));
pulp_run(p);
pulp_free(p);
return 0;
}
|
