src/common/threads.c

@@ -136,13 +136,12 @@ static c11_thrd_retval_t _thrdpool_worker(void* arg) {
                 break;
             }
         }
-        // sync point
-        atomic_fetch_add_explicit(&p_tasks->completed_count, completed_count, memory_order_release);
+        atomic_fetch_add_explicit(&p_tasks->completed_count, completed_count, memory_order_relaxed);
 
         c11_thrdpool_debug_log(p_worker->index,
                                "Execution complete, waiting for `sync_val` reset...");
         while(true) {
-            int sync_val = atomic_load_explicit(&p_tasks->sync_val, memory_order_relaxed);
+            int sync_val = atomic_load(&p_tasks->sync_val);
             if(sync_val == 0) break;
             if(sync_val == -1) return 0;  // force kill
             c11_thrd__yield();
@@ -155,13 +154,13 @@ static c11_thrd_retval_t _thrdpool_worker(void* arg) {
 
 void c11_thrdpool__ctor(c11_thrdpool* pool, int length) {
     pool->length = length;
-    atomic_store_explicit(&pool->ready_workers_num, 0, memory_order_relaxed);
+    atomic_store(&pool->ready_workers_num, 0);
     pool->workers = PK_MALLOC(sizeof(c11_thrdpool_worker) * length);
 
     c11_mutex__ctor(&pool->workers_mutex);
     c11_cond__ctor(&pool->workers_cond);
 
-    atomic_store_explicit(&pool->tasks.sync_val, 0, memory_order_relaxed);
+    atomic_store(&pool->tasks.sync_val, 0);
 
     for(int i = 0; i < length; i++) {
         c11_thrdpool_worker* p_worker = &pool->workers[i];
@@ -177,7 +176,7 @@ void c11_thrdpool__ctor(c11_thrdpool* pool, int length) {
 
 void c11_thrdpool__dtor(c11_thrdpool* pool) {
     c11_mutex__lock(&pool->workers_mutex);
-    atomic_store_explicit(&pool->tasks.sync_val, -1, memory_order_relaxed);
+    atomic_store(&pool->tasks.sync_val, -1);
     c11_thrdpool_debug_log(-1, "Terminating all workers...");
     c11_cond__broadcast(&pool->workers_cond);
     c11_mutex__unlock(&pool->workers_mutex);
@@ -213,11 +212,12 @@ void c11_thrdpool__map(c11_thrdpool* pool, c11_thrdpool_func_t func, void** args
 
     // wait for complete
     c11_thrdpool_debug_log(-1, "Waiting for %d tasks to complete...", num_tasks);
-    while(atomic_load_explicit(&pool->tasks.completed_count, memory_order_acquire) < num_tasks) {
+    while(atomic_load_explicit(&pool->tasks.completed_count, memory_order_relaxed) < num_tasks) {
         c11_thrd__yield();
     }
 
-    atomic_store_explicit(&pool->tasks.sync_val, 0, memory_order_relaxed);
+    // the last sync point
+    atomic_store(&pool->tasks.sync_val, 0);
     c11_thrdpool_debug_log(-1, "All %d tasks completed, `sync_val` was reset.", num_tasks);
 }
 

src/interpreter/objectpool.c

@@ -107,8 +107,8 @@ static int Pool__sweep_dealloc(Pool* self,
         if(item->unused_length == item->block_count) {
             // all free
             if(arenas->length > 0) {
-                // keep at least 1 arena
-                PK_FREE(item);
+                // at least one arena
+                PoolArena__delete(item);
             } else {
                 // no arena
                 c11_vector__push(PoolArena*, arenas, item);
@@ -127,7 +127,7 @@ static int Pool__sweep_dealloc(Pool* self,
         } else {
             if(item->unused_length == item->block_count) {
                 // all free
-                PK_FREE(item);
+                PoolArena__delete(item);
             } else {
                 // some free
                 c11_vector__push(PoolArena*, arenas, item);

src2/test_threads.c

@@ -24,7 +24,7 @@ int main(int argc, char** argv) {
     long long* data = PK_MALLOC(sizeof(long long) * num_tasks);
     void** args = PK_MALLOC(sizeof(void*) * num_tasks);
 
-    for(int i = 0; i < 10; i++) {
+    for(int i = 0; i < 3; i++) {
         for(int i = 0; i < num_tasks; i++) {
             data[i] = i;
             args[i] = &data[i];
@@ -42,9 +42,6 @@ int main(int argc, char** argv) {
                data[100],
                data[400]);
         printf("  Elapsed time for %d tasks: %.6f seconds\n", num_tasks, elapsed);
-        for(int i = 0; i < 5000000; i++) {
-            c11_thrd__yield();
-        }
     }
 
     c11_thrdpool__dtor(&pool);