FilesExpand file tree

 async3

/

test_pthread_volatile.cpp

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

60 lines (52 loc) · 1.38 KB

 async3

/

test_pthread_volatile.cpp

Top

File metadata and controls

• Code
• Blame

60 lines (52 loc) · 1.38 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

49

50

51

52

53

54

55

56

57

58

59

60

// Copyright 2015 The Emscripten Authors. All rights reserved.

// Emscripten is available under two separate licenses, the MIT license and the

// University of Illinois/NCSA Open Source License. Both these licenses can be

// found in the LICENSE file.

#include <pthread.h>

#include <errno.h>

#include <emscripten.h>

#include <emscripten/threading.h>

// Toggle to use two different methods for updating shared data (C++03 volatile vs explicit atomic ops).

// Note that using a volatile variable explicitly depends on x86 strong memory model semantics.

//#define USE_C_VOLATILE

volatile int sharedVar = 0;

static void *thread_start(void *arg) // thread: just flip the shared flag and quit.

{

#ifdef USE_C_VOLATILE

sharedVar = 1;

#else

emscripten_atomic_store_u32((void*)&sharedVar, 1);

#endif

pthread_exit(0);

}

int main()

{

int result;

if (!emscripten_has_threading_support())

{

#ifdef REPORT_RESULT

REPORT_RESULT(1);

#endif

printf("Skipped: Threading is not supported.\n");

return 0;

}

pthread_t thr;

int rc = pthread_create(&thr, NULL, thread_start, (void*)0);

if (rc != 0)

{

#ifdef REPORT_RESULT

int result = (rc != EAGAIN);

REPORT_RESULT(result);

return 0;

#endif

}

#ifdef USE_C_VOLATILE

while(sharedVar == 0)

;

#else

while(emscripten_atomic_load_u32((void*)&sharedVar) == 0) {}

#endif

#ifdef REPORT_RESULT

REPORT_RESULT(sharedVar);

#endif

}