File: test_pthread_nested_work_queue.c

package info (click to toggle)
emscripten 3.1.6~dfsg-5
  • links: PTS, VCS
  • area: main
  • in suites: bookworm
  • size: 114,112 kB
  • sloc: ansic: 583,052; cpp: 391,943; javascript: 79,361; python: 54,180; sh: 49,997; pascal: 4,658; makefile: 3,426; asm: 2,191; lisp: 1,869; ruby: 488; cs: 142
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");
}