Блог

У меня есть большая структура, которую необходимо обработать. Поэтому я использую std async для выполнения этого в другом потоке. Вот простой пример ниже:

 #include <iostream>
#include <future>

 
using namespace std;

struct teststruct{
    float thisvalue[32][32][64];
};

void foo(teststruct thisdummy) {
    this_thread::sleep_for(chrono::milliseconds(234));
    cout << "hello";
}

int main() {
    teststruct thisteststruct;
    foo(thisteststruct); // this does work
    auto futurevalue = async(launch::async, foo, thisteststruct); //this doesnt work

    return 0;
}
  

У меня есть структура, которая представляет собой просто большой 3D-массив с плавающей точкой. Когда я запускаю это, я получаю сообщение об ошибке с ошибкой шины: 10. Просто вызов foo без использования async работает, но с использованием std async это не работает. Каким-то образом это связано с размером структуры, поскольку, когда я создаю структуру

 struct teststruct{
        float thisvalue[32][32][63];
};
  

это волшебным образом работает. Я попытался разделить структуру наполовину, чтобы вместо массива 32x32x32 вместо массива 32x32x64 и использовать teststructs в качестве параметров, но это не работает. Как я уже говорил выше, я думаю, что это связано с размером структуры. Как я могу это исправить?

Вероятно, вы раздуваете стек.

sizeof(teststruct) есть 32*32*64*sizeof(float) . Предполагая 4-байтовое значение с плавающей запятой, это 256 КБ, которые вы пытаетесь передать по значению foo .

Хотя есть флаги, которые вы можете передать компилятору для увеличения размера стека, вы действительно хотите избежать передачи больших объектов по значению. Поскольку для этого требуется создание копии в памяти. Передайте эту большую структуру с помощью shared_pointer . Это позволит передавать его в основном потоке и в асинхронном потоке без использования какого-либо значительного объема стековой памяти. Это также быстрее, поскольку позволяет избежать большой копии этого объекта.

 #include <iostream>
#include <future>
#include <memory>

 
using namespace std;

struct teststruct{
    float thisvalue[32][32][64];
};


void foo(shared_ptr<teststruct> thisdummy) {
    this_thread::sleep_for(chrono::milliseconds(234));
    cout << "hello";
}

int main() {
    auto thisteststruct = make_shared<teststruct>();
    foo(thisteststruct);
    auto futurevalue = async(launch::async, foo, thisteststruct);

    return 0;
}
  

Превращение его в указатель или ссылку должно сработать.

(непроверенный)

 void foo(teststruct *thisdummy) {
    this_thread::sleep_for(chrono::milliseconds(234));
    cout << "hello";
}

int main() {
    teststruct thisteststruct;
    foo(amp;thisteststruct); // this does work
    auto futurevalue = async(launch::async, foo, amp;thisteststruct); //this doesnt work

    futurevalue.get();

    return 0;
}
  

О чем идет речь в приведенном ниже обсуждении, так это:

Если std::future, полученный из std::async, не перемещается или не привязывается к ссылке, деструктор std::future заблокирует в конце полного выражения до завершения асинхронной операции, по сути, делая код, такой как следующий синхронный:

Смотрите это