#include "custom_mutex.h"
Mutex mu(false, __tsan_mutex_write_reentrant);
long data;
void *thr1(void *arg) {
mu.Lock();
mu.~Mutex();
new(&mu) Mutex(true, __tsan_mutex_write_reentrant);
return 0;
}
void *thr2(void *arg) {
barrier_wait(&barrier);
mu.Lock();
data++;
mu.Unlock();
return 0;
}
int main() {
barrier_init(&barrier, 2);
pthread_t th;
pthread_create(&th, 0, thr1, 0);
pthread_join(th, 0);
barrier_init(&barrier, 2);
pthread_create(&th, 0, thr2, 0);
mu.Lock();
data++;
mu.Unlock();
barrier_wait(&barrier);
pthread_join(th, 0);
fprintf(stderr, "DONE\n");
return 0;
}