Changes in benchmark/schedint/pthreads.c [26fd986:b4107c8]

File:

• benchmark/schedint/pthreads.c (modified) (2 diffs)

benchmark/schedint/pthreads.c

@@ -6 +6 @@
 volatile int go = 0;
 
+pthread_cond_t c;
 pthread_mutex_t m;
-pthread_cond_t c;
 
 void __attribute__((noinline)) call() {
-        pthread_mutex_lock( &m );
-        pthread_cond_signal( &c );
-        pthread_mutex_unlock( &m );
+        pthread_mutex_lock(&m);
+        pthread_cond_signal(&c);
+        pthread_mutex_unlock(&m);
 }
 
-void __attribute__((noinline)) wait() {
+int  __attribute__((noinline)) wait() {
         pthread_mutex_lock(&m);
         go = 1;
-        for ( size_t i = 0; i < times; i++ ) {
-                pthread_cond_wait( &c, &m );
-        }
-        go = 0;
-        pthread_mutex_unlock( &m );
-}
-
-void * thread_main( __attribute__((unused)) void * arg ) {
-        while ( go == 0 ) { sched_yield(); } // waiter must start first
-        // barging for lock acquire => may not execute N times
         BENCH(
-                while ( go == 1 ) { call(); },
+                for (size_t i = 0; i < times; i++) {
+                        pthread_cond_wait(&c, &m);
+                },
                 result
         )
         printf( "%g\n", result );
+        go = 0;
+        pthread_mutex_unlock(&m);
+        return 0;
+}
+
+void* thread_main(__attribute__((unused)) void * arg ) {
+        while(go == 0) { sched_yield(); }
+        while(go == 1) { call(); }
         return NULL;
 }
@@ -39 +39 @@
         BENCH_START()
         pthread_t thread;
-        if ( pthread_create( &thread, NULL, thread_main, NULL ) < 0 ) {
+        if (pthread_create(&thread, NULL, thread_main, NULL) < 0) {
                 perror( "failure" );
                 return 1;
         }
         wait();
-        if ( pthread_join( thread, NULL ) < 0 ) {
+        if (pthread_join( thread, NULL) < 0) {
                 perror( "failure" );
                 return 1;