binaryen/test/example/cpp-threads.cpp at waitqueue-api · WebAssembly/binaryen · GitHub

History

60 lines (45 loc) · 1.62 KB

Raw

// test multiple uses of the threadPool

#include <cassert>

#include <iostream>

#include <thread>

#include <vector>

#include <binaryen-c.h>

int NUM_THREADS = 33;

void worker() {

BinaryenModuleRef module = BinaryenModuleCreate();

// Create a function type for i32 (i32, i32)

BinaryenType ii_[2] = {BinaryenTypeInt32(), BinaryenTypeInt32()};

BinaryenType ii = BinaryenTypeCreate(ii_, 2);

// Get the 0 and 1 arguments, and add them

BinaryenExpressionRef x = BinaryenLocalGet(module, 0, BinaryenTypeInt32()),

y = BinaryenLocalGet(module, 1, BinaryenTypeInt32());

BinaryenExpressionRef add = BinaryenBinary(module, BinaryenAddInt32(), x, y);

BinaryenExpressionRef ret = BinaryenReturn(module, add);

// Create the add function

// Note: no additional local variables

// Note: no basic blocks here, we are an AST. The function body is just an

// expression node.

BinaryenFunctionRef adder =

BinaryenAddFunction(module, "adder", ii, BinaryenTypeInt32(), NULL, 0, ret);

// validate it

assert(BinaryenModuleValidate(module));

// optimize it

BinaryenModuleOptimize(module);

assert(BinaryenModuleValidate(module));

// Clean up the module, which owns all the objects we created above

BinaryenModuleDispose(module);

}

int main() {

std::vector<std::thread> threads;

std::cout << "create threads...\n";

for (int i = 0; i < NUM_THREADS; i++) {

threads.emplace_back(worker);

}

std::cout << "threads running in parallel...\n";

std::cout << "waiting for threads to join...\n";

for (auto& thread : threads) {

thread.join();

}

std::cout << "all done.\n";

return 0;

}

binaryen/test/example/cpp-threads.cpp at waitqueue-api · WebAssembly/binaryen · GitHub

Uh oh!

Expand file tree

Breadcrumbs

cpp-threads.cpp

Latest commit

History

Breadcrumbs

cpp-threads.cpp

File metadata and controls