ultravideo / scalable-kvazaar Goto Github PK

PTHREAD_LOCK(&threadqueue->lock); 
 for (int i = 0; i < thread_count; i++) { 
   if (pthread_create(&threadqueue->threads[i], NULL, threadqueue_worker, threadqueue) != 0) { 
       fprintf(stderr, "pthread_create failed!\n"); 
       goto failed; 
   } 
   threadqueue->thread_count++; 
   threadqueue->thread_running_count++; 
 } 
 PTHREAD_UNLOCK(&threadqueue->lock); 

 return threadqueue;