Function TEST

test/threading.cpp:60–98

}

TEST(Threading, SimultaneousRead) {
    setDevice(0);

    array A = constant(1.0, 100, 100);
    array B = constant(1.0, 100, 100);

    vector<std::thread> tests;

    int thread_count    = 8;
    int iteration_count = 30;
    for (int t = 0; t < thread_count; ++t) {
        ArithOp op;
        float outValue;

        switch (t % 4) {
            case 0:
                op       = ADD;
                outValue = 2.0f;
                break;
            case 1:
                op       = SUB;
                outValue = 0.0f;
                break;
            case 2:
                op       = DIV;
                outValue = 1.0f;
                break;
            case 3:
                op       = MUL;
                outValue = 1.0f;
                break;
        }

        tests.emplace_back(calc, op, A, B, outValue, iteration_count);
    }

    for (int t = 0; t < thread_count; ++t)
        if (tests[t].joinable()) tests[t].join();
}

std::condition_variable cv;
std::mutex cvMutex;