Lines Matching refs:queueMutex
239 pthread_mutex_t queueMutex; member
253 pthread_mutex_destroy(&ctx->queueMutex); in TPool_free()
273 error |= pthread_mutex_init(&ctx->queueMutex, NULL); in TPool_create()
324 pthread_mutex_lock(&ctx->queueMutex); in TPool_thread()
332 pthread_mutex_unlock(&ctx->queueMutex); in TPool_thread()
335 pthread_cond_wait(&ctx->queuePopCond, &ctx->queueMutex); in TPool_thread()
344 pthread_mutex_unlock(&ctx->queueMutex); in TPool_thread()
349 pthread_mutex_lock(&ctx->queueMutex); in TPool_thread()
352 pthread_mutex_unlock(&ctx->queueMutex); in TPool_thread()
363 pthread_mutex_lock(&ctx->queueMutex); in TPool_shutdown()
365 pthread_mutex_unlock(&ctx->queueMutex); in TPool_shutdown()
381 pthread_mutex_lock(&ctx->queueMutex); in TPool_jobsCompleted()
383 pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in TPool_jobsCompleted()
385 pthread_mutex_unlock(&ctx->queueMutex); in TPool_jobsCompleted()
421 pthread_mutex_lock(&ctx->queueMutex); in TPool_submitJob()
424 pthread_cond_wait(&ctx->queuePushCond, &ctx->queueMutex); in TPool_submitJob()
427 pthread_mutex_unlock(&ctx->queueMutex); in TPool_submitJob()