Function tq_choke

fftools/thread_queue.c:258–268

}

void tq_choke(ThreadQueue *tq, int choked)
{
    pthread_mutex_lock(&tq->lock);

    int prev_choked = tq->choked;
    tq->choked = choked;
    if (choked != prev_choked)
        pthread_cond_broadcast(&tq->cond);

    pthread_mutex_unlock(&tq->lock);
}