diff options
| author | Tyge Løvset <[email protected]> | 2023-02-27 08:17:08 +0100 |
|---|---|---|
| committer | Tyge Løvset <[email protected]> | 2023-02-27 08:17:08 +0100 |
| commit | 75b57e30c8dd7a0598ae80b703faceb07908c3ed (patch) | |
| tree | be66be657879d8720be9e6eab2cd7c688e722fa4 | |
| parent | 1871ee8e9b4ca4edde387be973035c259fc9191f (diff) | |
| download | STC-modified-75b57e30c8dd7a0598ae80b703faceb07908c3ed.tar.gz STC-modified-75b57e30c8dd7a0598ae80b703faceb07908c3ed.zip | |
Simplified coroutine.h a bit and modified coroutines.c
| -rw-r--r-- | include/stc/algo/coroutine.h | 20 | ||||
| -rw-r--r-- | misc/examples/coroutines.c | 58 |
2 files changed, 36 insertions, 42 deletions
diff --git a/include/stc/algo/coroutine.h b/include/stc/algo/coroutine.h index 7ea53a0c..66b54366 100644 --- a/include/stc/algo/coroutine.h +++ b/include/stc/algo/coroutine.h @@ -61,15 +61,14 @@ int main(void) { #include <stc/ccommon.h> #define cco_begin(c) \ - int *_state = &(c)->cco_state, _nodyn; \ + int *_state = &(c)->cco_state; \ switch (*_state) { \ case 0: #define cco_end() \ *_state = 0; break; \ default: assert(!"missing cco_final: or illegal state"); \ - } \ - *_state *= -1; (void)_nodyn + } #define cco_yield(retval) \ do { \ @@ -88,19 +87,4 @@ int main(void) { #define cco_alive(c) ((c) && (c)->cco_state > 0) #define cco_stop(c) ((c)->cco_state = (c)->cco_state ? -1 : -2, c) -// --------------------------------------------------------------- - -#define cco_begin_dyn(cp) \ - if (!*(cp)) *(cp) = malloc(sizeof **(cp)), (*(cp))->cco_state = 0; \ - int* _state = &(*(cp))->cco_state, _dyn; \ - switch (*_state) { \ - case 0: - -#define cco_end_dyn(cp) \ - *_state = 0; break; \ - default: assert(!"missing cco_final: or illegal state"); \ - } \ - *_state *= -1; (void)_dyn; \ - free(*(cp)); *(cp) = NULL - #endif diff --git a/misc/examples/coroutines.c b/misc/examples/coroutines.c index 66a1275e..5d2a178a 100644 --- a/misc/examples/coroutines.c +++ b/misc/examples/coroutines.c @@ -2,6 +2,25 @@ #include <stdio.h> #include <stdint.h> +// Demonstrate to call another coroutine from a coroutine: +// First create a 2D iterator, then call fibonacci sequence: + +struct iterate { + int max_x, max_y; + int cco_state; + int x, y; +}; + +bool iterate(struct iterate* I) { + cco_begin(I); + for (I->x = 0; I->x < I->max_x; I->x++) + for (I->y = 0; I->y < I->max_y; I->y++) + cco_yield(true); + cco_final: + cco_end(); + return false; +} + // Use coroutine to create a fibonacci sequence generator: struct fibonacci { @@ -28,36 +47,27 @@ int64_t fibonacci(struct fibonacci* F) { return -1; } -// Demonstrate to call another coroutine from a coroutine: -// Create a 2D iterator, and call fibonacci sequence when x,y = 1,1: +// Combine -struct iterate { - int max_x, max_y; - int cco_state; - int x, y; +struct combine { + struct iterate it; + struct fibonacci fib; + int cco_state; }; -bool iterate(struct iterate* I, struct fibonacci* F) { - cco_begin(I); - for (I->x = 0; I->x < I->max_x; I->x++) { - for (I->y = 0; I->y < I->max_y; I->y++) { - if (I->x == 1 && I->y == 1) - cco_yield_coroutine(F, fibonacci(F), true); - else - cco_yield(true); - } - } - cco_final: - puts("final"); +bool combine(struct combine* C) { + cco_begin(C); + cco_yield_coroutine(&C->it, iterate(&C->it), true); + cco_yield_coroutine(&C->fib, fibonacci(&C->fib), true); + // May reuse the C->it context; state has been reset to 0. + cco_yield_coroutine(&C->it, iterate(&C->it), true); + cco_final: puts("final"); cco_end(); return false; } - int main(void) { - struct fibonacci fib = {.n = 14}; - struct iterate it = {3, 3}; - - while (iterate(&it, &fib)) - printf("Iter=(%d, %d). Fib=%lld\n", it.x, it.y, (long long)fib.a); + struct combine comb = {.it={3, 3}, .fib={14}}; + while (combine(&comb)) + printf("Iter=(%d, %d). Fib=%lld\n", comb.it.x, comb.it.y, (long long)comb.fib.a); } |
