aboutsummaryrefslogtreecommitdiff
path: root/example/demo1.cc
blob: b83c4340e90f1662eb3cd49cdaf70c9b931ee0c8 (plain) (blame)
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
/* Copyright (c) 2020 Johannes Stoelp */

#include "lib/executor.h"
#include "lib/thread.h"

#include <cstdio>
#include <memory>

struct TestThread : public nMatcha::Thread {
    TestThread(const char* name) : Thread(), mName(name) {}

    virtual void threadFn() override {
        printf("[TestThread(%s)] start -> yield\n", mName);
        yield();
        printf("[TestThread(%s)] yield -> done\n", mName);
    }

  private:
    const char* mName;
};

void freeThreadFn(nMatcha::Yielder& y) {
    puts("[freeThreadFn] start -> yield");
    y.yield();
    puts("[freeThreadFn] yield -> done");
}

int main() {
    puts("[main] start main thread");

    nMatcha::Executor e;
    e.spawn(std::make_unique<TestThread>("Thread1"));
    e.spawn(std::make_unique<TestThread>("Thread2"));
    e.spawn(std::make_unique<TestThread>("Thread3"));

    e.spawn(nMatcha::FnThread::make([](nMatcha::Yielder& y) {
        puts("[Lambda Thread] start -> yield");
        y.yield();
        puts("[Lambda Thread] yield -> done");
    }));

    e.spawn(nMatcha::FnThread::make(freeThreadFn));

    e.run();

    puts("[main] finish main thread");
    return 0;
}