Для примера есть вот такая функция:
auto lambda = [](int k)
{
size_t size = 1920 * 1080 * 3;
size_t repeatCount = 100;
char* ch = new char [size];
auto start = std::chrono::high_resolution_clock::now();
for (int i = 0; i < repeatCount; ++i)
{
for (int j = 0; j < size; ++j)
{
ch[j] = j % 255;
}
}
auto duration = std::chrono::duration<double, std::milli>(std::chrono::high_resolution_clock::now() - start).count() / repeatCount;
std::cout << k << " " << std::this_thread::get_id() << " " << duration << std::endl << std::flush;
delete [] ch;
};
Среднее время её выполнения при наличии в программе лишь основного потока: 4.60426 мс
Далее выполняю данную функцию в n-ом числе потоков (в данном случае - 9):
std::vector <std::future <void>> futures;
for (int k = 0; k < 9; ++k)
{
futures.push_back(std::async(std::launch::async, lambda, k));
}
Времена соответсвенно:
6.66124
6.86142
6.96151
7.12166
7.31183
7.32184
7.33185
7.47198
7.51201
Почему возросло время выполнения? В моей машине 6 ядер, 12 потоков. Машина во время выполнения тестов ничего другого не делала (нагрузка процессора не превышала 80%)
CPU : Ryzen 3600X 6-Core
OS : Win10 x64
compiler : mingw x64
Опции компилятора: g++ -c -fno-keep-inline-dllexport -O2 -std=gnu++11 -Wall -Wextra -Wextra -fexceptions -mthreads -DUNICODE -D_UNICODE -DWIN32 -DMINGW_HAS_SECURE_API=1 -DQT_DEPRECATED_WARNINGS -DQT_NO_DEBUG -DQT_CORE_LIB
UPD. На всякий случай минимально воспроизводимый пример:
#include <iostream>
#include <chrono>
#include <thread>
#include <vector>
#include <future>
int main(int argc, char *argv[])
{
auto lambda = [](int k)
{
size_t size = 1920 * 1080 * 3;
size_t repeatCount = 100;
char* ch = new char [size];
auto start = std::chrono::high_resolution_clock::now();
for (int i = 0; i < repeatCount; ++i)
{
for (int j = 0; j < size; ++j)
{
ch[j] = j % 255;
}
}
auto duration = std::chrono::duration<double, std::milli>(std::chrono::high_resolution_clock::now() - start).count() / repeatCount;
std::cout << k << " " << std::this_thread::get_id() << " " << duration << std::endl << std::flush;
delete [] ch;
};
lambda(-1);
std::vector <std::future <void>> futures;
for (int k = 0; k < 9; ++k)
{
futures.push_back(std::async(std::launch::async, lambda, k));
}
return 0;
}
UPD 2: использование сырых тредов не меняет ситуации:
std::vector <std::thread> threads;
for (int k = 0; k < 9; ++k)
{
threads.push_back(std::move(std::thread(lambda, k)));
}
for (auto& thread : threads)
{
thread.join();
}
5.20472
6.15558
6.22565
6.59598
6.67605
6.68598
6.73603
7.50681
7.52675
for (int i = 0; i < repeatCount; ++i)
оптимизатор, по идее, должен вообще выбросить, т.к. он не влияет на наблюдаемое поведение программы...