source: tests/concurrent/suspend_then.cfa @ d658183

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationnew-astnew-ast-unique-exprpthread-emulationqualifiedEnum
Last change on this file since d658183 was dfa4360, checked in by Thierry Delisle <tdelisle@…>, 4 years ago

Added several tests for generators

  • Property mode set to 100644
File size: 1.5 KB
RevLine 
[5b11c25]1#include <fstream.hfa>
2#include <kernel.hfa>
[f019069]3#include <thread.hfa>
[5b11c25]4#include <time.hfa>
[f019069]5#include <stdlib.hfa>
6#include <string.h>
[5b11c25]7
8#define __kick_rate 150000ul
9#include "long_tests.hfa"
10
11Duration default_preemption() {
[dfa4360]12        return 0;
[5b11c25]13}
14
15#ifdef TEST_LONG
16static const unsigned long N = 600_000ul;
17#else
18static const unsigned long N = 1_000ul;
19#endif
20
21#if !defined(TEST_FOREVER)
[f019069]22        static inline void print(const char * const text ) {
[dfa4360]23                write( STDOUT_FILENO, text, strlen(text) );
[b9696a8]24        }
[5b11c25]25#else
26        static inline void print(Printer & this, const char * const text ) {}
27#endif
28
[dfa4360]29generator Coroutine { int i; };
[5b11c25]30
31volatile bool done = false;
32Coroutine * volatile the_cor = 0p;
33
[b9696a8]34void store(Coroutine & cor) {
35        __atomic_store_n(&the_cor, &cor, __ATOMIC_SEQ_CST);
[5b11c25]36}
37
[b9696a8]38Coroutine * take(void) {
39        Coroutine * val = 0p;
40        Coroutine * ret = __atomic_exchange_n(&the_cor, val, __ATOMIC_SEQ_CST);
41        assert(!ret || !the_cor);
42        return ret;
[5b11c25]43}
44
45void main(Coroutine& this) {
[dfa4360]46        this.i = 0;
[427854b]47        suspend;
[dfa4360]48        for(;TEST(this.i < N); this.i++) {
[5b11c25]49
[dfa4360]50                print("C - Suspending\n");
[427854b]51                suspend{
[dfa4360]52                        print("C - Publishing\n");
[5b11c25]53                        assert(!the_cor);
[b9696a8]54                        store( this );
[5b11c25]55                }
[b9696a8]56                assert(!the_cor);
[dfa4360]57                print("C - Back\n");
[5b11c25]58                KICK_WATCHDOG;
59                yield();
60        }
61        done = true;
[427854b]62        suspend;
[5b11c25]63}
64
65thread Thread {};
66void main(Thread & this) {
67        Coroutine * mine = 0p;
68        while(!done) {
69                yield();
70
[b9696a8]71                mine = take();
[5b11c25]72                if(!mine) continue;
73
[dfa4360]74                print("T - took\n");
[5b11c25]75                resume(*mine);
76        }
77}
78
79
80int main(int argc, char* argv[]) {
81        processor p[2];
82        Coroutine c;
[b9696a8]83        resume(c); // Prime the coroutine to avoid one of the threads being its starter
[5b11c25]84        the_cor = &c;
85        {
86                Thread t[2];
87        }
88}
Note: See TracBrowser for help on using the repository browser.