Searched refs:queueMutex (Results 1 – 3 of 3) sorted by relevance
53 ZSTD_pthread_mutex_t queueMutex; member72 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()80 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()83 ZSTD_pthread_cond_wait(&ctx->queuePopCond, &ctx->queueMutex); in POOL_thread()92 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()97 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_thread()100 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_thread()136 error |= ZSTD_pthread_mutex_init(&ctx->queueMutex, NULL); in POOL_create_advanced()167 ZSTD_pthread_mutex_lock(&ctx->queueMutex); in POOL_join()169 ZSTD_pthread_mutex_unlock(&ctx->queueMutex); in POOL_join()[all …]
239 pthread_mutex_t queueMutex; member253 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()[all …]
99 std::mutex queueMutex; in main() local106 std::lock_guard<std::mutex> lg(queueMutex); in main()118 std::lock_guard<std::mutex> lg(queueMutex); in main()135 std::lock_guard<std::mutex> lg(queueMutex); in main()