Function TEST

autotest/cpp/testthreadcond.cpp:120–150

}

TEST(testthreadcond, test)
{
    int i;
    CPLJoinableThread *apThreads[10];

    bVerbose = CPLTestBool(CPLGetConfigOption("VERBOSE", "NO"));

    hCond = CPLCreateCond();
    hCondJobFinished = CPLCreateCond();

    hClientMutex = CPLCreateMutex();
    CPLReleaseMutex(hClientMutex);

    CPLCreateThread(ProducerThread, nullptr);

    for (i = 0; i < 10; i++)
    {
        int *pi = (int *)malloc(sizeof(int));
        *pi = i;
        apThreads[i] = CPLCreateJoinableThread(ConsumerThread, pi);
    }

    for (i = 0; i < 10; i++)
    {
        CPLJoinThread(apThreads[i]);
    }

    CPLDestroyCond(hCond);
    CPLDestroyCond(hCondJobFinished);
    CPLDestroyMutex(hClientMutex);
}

}  // namespace