Changes in libcfa/src/concurrency/pthread.cfa [6b33e89:c3d0182a]

File:

• libcfa/src/concurrency/pthread.cfa (modified) (5 diffs)

libcfa/src/concurrency/pthread.cfa

@@ -9 +9 @@
 // Author           : Zhenyan Zhu
 // Created On       : Sat Aug 6 16:29:18 2022
-// Last Modified By : Peter A. Buhr
-// Last Modified On : Fri Apr 25 07:28:01 2025
-// Update Count     : 4
+// Last Modified By : Kyoung Seo
+// Last Modified On : Mon Jan 27 20:35:00 2025
+// Update Count     : 1
 //
 
@@ -40 +40 @@
         bool in_use;
         void (* destructor)( void * );
-        dlist( pthread_values ) threads;
+    dlist( pthread_values ) threads;
 };
 
@@ -543 +543 @@
                 //      p.in_use = false;
                 // }
-                for ( pthread_values * p = &remove_first( cfa_pthread_keys[key].threads ); p; p = &remove_first( cfa_pthread_keys[key].threads ) ) {
-                        p->in_use = false;
-                }
+        pthread_values * p = &try_pop_front( cfa_pthread_keys[key].threads );
+        for ( ; p; ) {            
+            p->in_use = false;
+            p = &try_pop_front( cfa_pthread_keys[key].threads );
+        }
                 unlock(key_lock);
                 return 0;
@@ -601 +603 @@
         //######################### Parallelism #########################
         void pthread_delete_kernel_threads_() __THROW { // see uMain::~uMain
-                
-                for ( Pthread_kernel_threads * p = &remove_first(cfa_pthreads_kernel_threads); p; p = &remove_first(cfa_pthreads_kernel_threads) ) {
-                        delete(p);
+                Pthread_kernel_threads * p = &try_pop_front(cfa_pthreads_kernel_threads);
+                for ( ; p; ) {
+            delete(p);
+                        p = &try_pop_front(cfa_pthreads_kernel_threads);
                 } // for
         } // pthread_delete_kernel_threads_
@@ -623 +626 @@
                 } // for
                 for ( ; new_level < cfa_pthreads_no_kernel_threads; cfa_pthreads_no_kernel_threads -= 1 ) { // remove processors ?
-                        delete(&remove_first(cfa_pthreads_kernel_threads));
+                        delete(&try_pop_front(cfa_pthreads_kernel_threads));
                 } // for
                 unlock( concurrency_lock );