2011-07-04 14 views
1

新しいC++スレッドライブラリを試し始めました。最後にいくつかの計算タスクを並列に実行しました。この例では、実行に1秒かかると思いますが、終了時にクラッシュします。私が間違っていることのアイデア?C++ 0xスレッディングライブラリを使用して終了時にクラッシュする

#include <future> 
#include <vector> 
#include <iostream> 

int main() { 
    std::vector<std::thread> workingTasks; 
    std::vector<std::future<int>> output; 
    for (int i = 0; i < 6; ++i) { 
     std::packaged_task<int()> pt(std::bind([](int data){ sleep(1); return data*data;}, i)); 
     output.push_back(pt.get_future()); 
     std::thread task(std::move(pt)); // launch task on a thread 
     workingTasks.push_back(std::move(task)); 
    } 

    for (int i = 0; i < output.size(); ++i) { 
     std::cout << i << ": " << output[i].get() << std::endl; 
    } 
} 

次のようにgdbバックトレースは次のとおりです。

Program received signal SIGABRT, Aborted. 0x0000003e45e330c5 in raise (sig=6) at ../nptl/sysdeps/unix/sysv/linux/raise.c:64 64  return INLINE_SYSCALL (tgkill, 3, pid, selftid, sig); 
(gdb) bt 
#0 0x0000003e45e330c5 in raise (sig=6) at ../nptl/sysdeps/unix/sysv/linux/raise.c:64 
#1 0x0000003e45e34a76 in abort() at abort.c:92 
#2 0x0000003e496bc08d in __gnu_cxx::__verbose_terminate_handler() 
    at ../../../../libstdc++-v3/libsupc++/vterminate.cc:93 
#3 0x0000003e496ba2a6 in __cxxabiv1::__terminate (handler=<value optimized out>) 
    at ../../../../libstdc++-v3/libsupc++/eh_terminate.cc:39 
#4 0x0000003e496ba2d3 in std::terminate() at ../../../../libstdc++-v3/libsupc++/eh_terminate.cc:49 
#5 0x0000000000402d71 in std::thread::~thread (this=0x612d50, 
__in_chrg=<value optimized out>) 
    at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/thread:146 
#6 0x0000000000407052 in std::_Destroy<std::thread> (__pointer=0x612d50) 
    at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/bits/stl_construct.h:89 
#7 0x0000000000406468 in std::_Destroy_aux<false>::__destroy<std::thread*> (__first=0x612d50, 
    __last=0x612d80) 
    at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/bits/stl_construct.h:99 
#8 0x00000000004053fd in std::_Destroy<std::thread*> (__first=0x612d50, __last=0x612d80) 
    at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/bits/stl_construct.h:122 
#9 0x0000000000404963 in std::_Destroy<std::thread*, std::thread> (__first=0x612d50, 
__last=0x612d80) 
    at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/bits/stl_construct.h:148 
#10 0x0000000000403caa in std::vector<std::thread, std::allocator<std::thread> >::~vector (
    this=0x7fffffffddd0, __in_chrg=<value optimized out>) 
    at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/bits/stl_vector.h:313 
#11 0x0000000000401f9c in main() at main.cpp:18 
+0

エラーメッセージは? –

答えて

4

私は問題を発見しました。 std :: threadは実際には低レベルのプリミティブであり、正しく動作するためにはjoin()が必要です。出力部分がクラッシュを修正した後、次のコードを追加してください。

for (int i = 0; i < workingTasks.size(); ++i) { 
    workingTasks[i].join(); 
} 
+0

完全に安全であるためには、例外パスを保護する必要があります( 'workingTasks'が巻き戻しによって破棄された場合、参加または分離を選択してください)。この小さな例では、例外はとにかく終了することになります。 –

関連する問題