Function ThreadMain

test/pthread/test_pthread_64bit_atomics.c:35–80

}

void *ThreadMain(void *arg) {
  assert(pthread_self() != 0);
  assert(globalDouble == 5.0);
  assert(globalU64 == 5);
  struct Test *t = (struct Test*)arg;
  emscripten_outf("Thread %d for test %d: starting computation", t->threadId, t->op);

  for (int i = 0; i < 99999; ++i) {
    for (int j = 0; j < DATA_COUNT; ++j) {
      switch (t->op) {
        case 0: emscripten_atomic_add_u64(&sharedData[j], 1); break;
        case 1: emscripten_atomic_sub_u64(&sharedData[j], 1); break;
        case 2: emscripten_atomic_and_u64(&sharedData[j], ~(1UL << t->threadId)); break;
        case 3: emscripten_atomic_or_u64(&sharedData[j], 1UL << t->threadId); break;
        case 4: emscripten_atomic_xor_u64(&sharedData[j], 1UL << t->threadId); break;
        case 5: {
          // Atomically load and store data, and test that each individual u8 is the same.
          uint64_t data = emscripten_atomic_load_u64(&sharedData[j]);
          uint8_t dataU8[8];
          memcpy(dataU8, &data, 8);
          assert(dataU8[0] >= 10 && dataU8[0] < 10+NUM_THREADS);
          assert(dataU8[0] == dataU8[1] && dataU8[0] == dataU8[2] && dataU8[0] == dataU8[3]);
          assert(dataU8[0] == dataU8[4] && dataU8[0] == dataU8[5] && dataU8[0] == dataU8[6] && dataU8[0] == dataU8[7]);
          dataU8[0] = dataU8[1] = dataU8[2] = dataU8[3] = dataU8[4] = dataU8[5] = dataU8[6] = dataU8[7] = 10 + t->threadId;
          memcpy(&data, dataU8, 8);
          emscripten_atomic_store_u64(&sharedData[j], data);
        }
        break;
        case 6: {
          uint64_t newData = rand_60();
          uint64_t data;
          uint64_t prevData;
          do {
            data = emscripten_atomic_load_u64(&sharedData[j]);
            prevData = emscripten_atomic_cas_u64(&sharedData[j], data, newData);
          } while(prevData != data);
          threadCasAccumulatedReadData[t->threadId] += data;
          threadCasAccumulatedWrittenData[t->threadId] += newData;
        }
        break;
      }
    }
  }
  emscripten_outf("Thread %d for test %d: finished, exit()ing", t->threadId, t->op);
  pthread_exit(0);
}

struct Test t[NUM_THREADS] = {};
pthread_t thread[NUM_THREADS];