Function check_blocks

tests/BS_thread_pool_test.cpp:1814–1896

* @brief Check that detach_blocks() and submit_blocks() work using several different random values for the range of indices and number of tasks. */

 * @brief Check that detach_blocks() and submit_blocks() work using several different random values for the range of indices and number of tasks.
 */
void check_blocks()
{
    constexpr std::int64_t range = 1000000;
    constexpr std::size_t repeats = 10;
    BS::thread_pool pool;
    for (std::size_t i = 0; i < repeats; ++i)
    {
        const std::pair<std::int64_t, std::int64_t> indices = random_pair(-range, range);
        check(check_blocks_no_return(pool, indices.first, indices.second, random<std::size_t>(1, pool.get_thread_count()), "detach_blocks()"));
    }
    for (std::size_t i = 0; i < repeats; ++i)
    {
        const std::pair<std::int64_t, std::int64_t> indices = random_pair(-range, range);
        check(check_blocks_no_return(pool, indices.first, indices.second, random<std::size_t>(1, pool.get_thread_count()), "submit_blocks()"));
    }
    for (std::size_t i = 0; i < repeats; ++i)
    {
        const std::pair<std::int64_t, std::int64_t> indices = random_pair(-range, range);
        check_blocks_return(pool, indices.first, indices.second, random<std::size_t>(1, pool.get_thread_count()));
    }
    logln("Verifying that detach_blocks() with identical start and end indices does nothing...");
    {
        std::atomic<std::size_t> count = 0;
        const std::int64_t index = random(-range, range);
        logln("Range: ", index, " to ", index);
        pool.detach_blocks(index, index,
            [&count](const std::int64_t, const std::int64_t)
            {
                ++count;
            });
        pool.wait();
        check(count == 0);
    }
    logln("Verifying that submit_blocks() with identical start and end indices does nothing...");
    {
        std::atomic<std::size_t> count = 0;
        const std::int64_t index = random(-range, range);
        logln("Range: ", index, " to ", index);
        pool.submit_blocks(index, index,
                [&count](const std::int64_t, const std::int64_t)
                {
                    ++count;
                })
            .wait();
        check(count == 0);
    }
    logln("Verifying that detach_blocks() with end index smaller than the start index does nothing...");
    {
        std::atomic<std::size_t> count = 0;
        const std::pair<std::int64_t, std::int64_t> indices = random_pair(-range, range);
        logln("Range: ", indices.second, " to ", indices.first);
        pool.detach_blocks(indices.second, indices.first,
            [&count](const std::int64_t, const std::int64_t)
            {
                ++count;
            });
        pool.wait();
        check(count == 0);