File: test_pthread_nested_work_queue.c

package info (click to toggle)
emscripten 3.1.69%2Bdfsg-4
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 121,872 kB
  • sloc: ansic: 636,110; cpp: 425,974; javascript: 78,401; python: 58,404; sh: 49,154; pascal: 5,237; makefile: 3,365; asm: 2,415; lisp: 1,869
file content (37 lines) | stat: -rw-r--r-- 899 bytes parent folder | download | duplicates (3)
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
#include <stdio.h>
#include <stdbool.h>
#include <stdatomic.h>
#include <emscripten/threading.h>
#include <emscripten/emscripten.h>

atomic_bool work_done = false;

void work() {
  // This `work` item is called from within
  // `emscripten_current_thread_process_queued_calls`.
  // Calling `emscripten_thread_sleep` here will trigger another nested call to
  // `emscripten_current_thread_process_queued_calls`.
  printf("Begin work\n");
  emscripten_thread_sleep(1);
  work_done = true;
  printf("End work\n");
}

void* thread_func(void* _param) {
  printf("Start thread\n");
  while (!work_done) {
    emscripten_thread_sleep(1);
  }
  printf("End thread\n");
  return NULL;
};

int main() {
  pthread_t thread;
  pthread_create(&thread, NULL, thread_func, (void *)0);

  emscripten_dispatch_to_thread(thread, EM_FUNC_SIG_V, &work, 0);

  pthread_join(thread, NULL);
  printf("Test finish\n");
}