Повторное выбрасывание исключения из блока OpenMP с основным потоком с помощью Rcpp

В ответ на этот вопрос я ищу решение для перехвата одной из ошибок, возникающих внутри блока OpenMP, а затем перебросить его с основным потоком после блока OpenMP при вызове кода C++ из R с использованием Rcpp. Другой вопрос, что происходит не так.

Я следил за ответом здесь и пробовал с std::exception_ptr. Кажется, это работает почти на всех платформах и компиляторах, за исключением Fedora с clang-11, использующим libc++. Вот пример:

// openmp-exception-issue.cpp
#include <omp.h>
#include <exception>
#include <stdexcept>

// [[Rcpp::plugins(openmp)]]
#include <Rcpp.h>

// [[Rcpp::export()]]
double that_cpp_func(int const n_it){
  std::exception_ptr Ptr = nullptr;
  bool is_set = false;
  double out(0.);

#pragma omp parallel for num_threads(4) reduction(+:out)
  for(int i = 0; i < n_it; ++i)
    try
    {
      if(i > -1)
        throw std::runtime_error("boh :(");
      out += i;
    }
    catch (...)
    {
#pragma omp critical
      if(!is_set){
        Ptr = std::current_exception();
        is_set = true;
      }
    }

  if(Ptr)
    std::rethrow_exception(Ptr);

  return out;
}

Запуск (вам нужно будет изменить путь)

/root/R-devel/bin/R -d valgrind -e "Rcpp::sourceCpp('/sdir/openmp-exception-issue.cpp'); that_cpp_func(100)"

с приведенной ниже настройкой дает следующее:

==15467== Memcheck, a memory error detector
==15467== Copyright (C) 2002-2017, and GNU GPL'd, by Julian Seward et al.
==15467== Using Valgrind-3.16.1 and LibVEX; rerun with -h for copyright info
==15467== Command: /root/R-devel/bin/exec/R -e Rcpp::sourceCpp('/sdir/openmp-exception-issue.cpp');~+~that_cpp_func(100)
==15467== 

R Under development (unstable) (2021-02-24 r80033) -- "Unsuffered Consequences"
Copyright (C) 2021 The R Foundation for Statistical Computing
Platform: x86_64-pc-linux-gnu (64-bit)

...

> Rcpp::sourceCpp('/sdir/openmp-exception-issue.cpp'); that_cpp_func(100)
In file included from openmp-exception-issue.cpp:7:
In file included from /root/R-devel/library/Rcpp/include/Rcpp.h:57:
/root/R-devel/library/Rcpp/include/Rcpp/DataFrame.h:136:18: warning: unused variable 'data' [-Wunused-variable]
            SEXP data = Parent::get__();
                 ^
1 warning generated.
==15467== Syscall param sched_setaffinity(mask) points to unaddressable byte(s)
==15467==    at 0x550F55D: syscall (in /usr/lib64/libc-2.32.so)
==15467==    by 0x539AD1C: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x536AAE9: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535774A: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x5357B8C: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB07: that_cpp_func(int) (openmp-exception-issue.cpp:10)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467==    by 0x4EED11: R_execClosure (eval.c:0)
==15467==    by 0x4EE288: Rf_applyClosure (eval.c:1823)
==15467==  Address 0x0 is not stack'd, malloc'd or (recently) free'd
==15467== 
==15467== Invalid read of size 8
==15467==    at 0x71EC2DF: __cxa_end_catch (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0x10B0FE08: .omp_outlined._debug__ (openmp-exception-issue.cpp:30)
==15467==    by 0x10B0FE08: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467==    by 0x4EED11: R_execClosure (eval.c:0)
==15467==  Address 0x99d3990 is 96 bytes inside a block of size 144 free'd
==15467==    at 0x483A9F5: free (vg_replace_malloc.c:538)
==15467==    by 0xB6AE48A: __cxa_decrement_exception_refcount (in /usr/lib64/libc++abi.so.1.0)
==15467==    by 0x10B0FDE9: .omp_outlined._debug__ (openmp-exception-issue.cpp:27)
==15467==    by 0x10B0FDE9: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467==  Block was alloc'd at
==15467==    at 0x4839809: malloc (vg_replace_malloc.c:307)
==15467==    by 0x71EC0C3: __cxa_allocate_exception (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0x10B0FD64: .omp_outlined._debug__ (openmp-exception-issue.cpp:20)
==15467==    by 0x10B0FD64: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467== 
10 more errors...
==15467== 
==15467== Invalid free() / delete / delete[] / realloc()
==15467==    at 0x483AEDD: operator delete(void*) (vg_replace_malloc.c:584)
==15467==    by 0x72030FB: std::runtime_error::~runtime_error() (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0xB6AE47E: __cxa_decrement_exception_refcount (in /usr/lib64/libc++abi.so.1.0)
==15467==    by 0x10B0FBC0: that_cpp_func(int) (openmp-exception-issue.cpp:36)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467==    by 0x4EED11: R_execClosure (eval.c:0)
==15467==    by 0x4EE288: Rf_applyClosure (eval.c:1823)
==15467==    by 0x4D512D: Rf_eval (eval.c:850)
==15467==    by 0x523CC9: Rf_ReplIteration (main.c:264)
==15467==  Address 0x9604a10 is 0 bytes inside a block of size 31 free'd
==15467==    at 0x483AEDD: operator delete(void*) (vg_replace_malloc.c:584)
==15467==    by 0x72030FB: std::runtime_error::~runtime_error() (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0xB6AE47E: __cxa_decrement_exception_refcount (in /usr/lib64/libc++abi.so.1.0)
==15467==    by 0x10B0FDE9: .omp_outlined._debug__ (openmp-exception-issue.cpp:27)
==15467==    by 0x10B0FDE9: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==  Block was alloc'd at
==15467==    at 0x4839E7D: operator new(unsigned long) (vg_replace_malloc.c:342)
==15467==    by 0x7213B20: ??? (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0x7213CB6: ??? (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0x721409D: std::runtime_error::runtime_error(char const*) (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0x10B0FD72: .omp_outlined._debug__ (openmp-exception-issue.cpp:20)
==15467==    by 0x10B0FD72: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467== 
==15467== Invalid free() / delete / delete[] / realloc()
==15467==    at 0x483A9F5: free (vg_replace_malloc.c:538)
==15467==    by 0xB6AE48A: __cxa_decrement_exception_refcount (in /usr/lib64/libc++abi.so.1.0)
==15467==    by 0x10B0FBC0: that_cpp_func(int) (openmp-exception-issue.cpp:36)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467==    by 0x4EED11: R_execClosure (eval.c:0)
==15467==    by 0x4EE288: Rf_applyClosure (eval.c:1823)
==15467==    by 0x4D512D: Rf_eval (eval.c:850)
==15467==    by 0x523CC9: Rf_ReplIteration (main.c:264)
==15467==    by 0x52545F: R_ReplConsole (main.c:314)
==15467==  Address 0x99d3930 is 0 bytes inside a block of size 144 free'd
==15467==    at 0x483A9F5: free (vg_replace_malloc.c:538)
==15467==    by 0xB6AE48A: __cxa_decrement_exception_refcount (in /usr/lib64/libc++abi.so.1.0)
==15467==    by 0x10B0FDE9: .omp_outlined._debug__ (openmp-exception-issue.cpp:27)
==15467==    by 0x10B0FDE9: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467==  Block was alloc'd at
==15467==    at 0x4839809: malloc (vg_replace_malloc.c:307)
==15467==    by 0x71EC0C3: __cxa_allocate_exception (in /usr/lib64/libstdc++.so.6.0.28)
==15467==    by 0x10B0FD64: .omp_outlined._debug__ (openmp-exception-issue.cpp:20)
==15467==    by 0x10B0FD64: .omp_outlined. (openmp-exception-issue.cpp:15)
==15467==    by 0x53B27C2: __kmp_invoke_microtask (in /usr/lib64/libomp.so)
==15467==    by 0x5358068: ??? (in /usr/lib64/libomp.so)
==15467==    by 0x535BFF2: __kmp_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x534A740: __kmpc_fork_call (in /usr/lib64/libomp.so)
==15467==    by 0x10B0FB63: that_cpp_func(int) (openmp-exception-issue.cpp:15)
==15467==    by 0x10B0FEAA: sourceCpp_1_that_cpp_func (openmp-exception-issue.cpp:47)
==15467==    by 0x49DA3A: R_doDotCall (dotcode.c:598)
==15467==    by 0x4A0510: do_dotcall (dotcode.c:1281)
==15467==    by 0x4D50BC: Rf_eval (eval.c:830)
==15467== 
1 more error...
Error in that_cpp_func(100) : c++ exception (unknown reason)
Calls: that_cpp_func -> .Call
Execution halted
==15467== 
==15467== HEAP SUMMARY:
==15467==     in use at exit: 55,351,131 bytes in 10,962 blocks
==15467==   total heap usage: 30,797 allocs, 19,837 frees, 94,080,022 bytes allocated
==15467== 
==15467== LEAK SUMMARY:
==15467==    definitely lost: 0 bytes in 0 blocks
==15467==    indirectly lost: 0 bytes in 0 blocks
==15467==      possibly lost: 0 bytes in 0 blocks
==15467==    still reachable: 55,351,131 bytes in 10,962 blocks
==15467==                       of which reachable via heuristic:
==15467==                         newarray           : 4,264 bytes in 1 blocks
==15467==         suppressed: 0 bytes in 0 blocks
==15467== Rerun with --leak-check=full to see details of leaked memory
==15467== 
==15467== For lists of detected and suppressed errors, rerun with: -s
==15467== ERROR SUMMARY: 32 errors from 18 contexts (suppressed: 0 from 0)

Кажется, он работает на всех других платформах и конфигурациях компиляторов, которые я тестировал. Я попытался сделать пример без Rcpp (пример на чистом C++), но это не приводит к ошибке, показанной выше.

Мотивирующим примером является мой пакет mdgc, который выдает следующую ошибку на CRAN r-devel-linux-x86_64-fedora-clang:

*** caught segfault ***
address 0xffffffff, cause 'memory not mapped'
An irrecoverable exception occurred. R is aborting now ...

Это согласуется с выводом Valgrind.

Обновлять

Вы также получите аналогичные ошибки, если удалите #pragma omp parallel for num_threads(4) reduction(+:out) и #pragma omp critical. т.е. это не связано с OpenMP.

Получение результата

Я выполнил следующее, чтобы получить результаты (например, r-devel-linux-x86_64-fedora-clang от CRAN):

sudo docker run -ti rhub/fedora-clang

export _R_CHECK_INSTALL_DEPENDS_=true
export _R_CHECK_SUGGESTS_ONLY_=true
export _R_CHECK_NO_RECOMMENDED_=true
export _R_CHECK_DOC_SIZES2_=true
export _R_CHECK_DEPRECATED_DEFUNCT_=true
export _R_CHECK_SCREEN_DEVICE_=warn
export _R_CHECK_REPLACING_IMPORTS_=true
export _R_CHECK_TOPLEVEL_FILES_=true
export _R_CHECK_DOT_FIRSTLIB_=true
export _R_CHECK_RD_LINE_WIDTHS_=true
export _R_CHECK_S3_METHODS_NOT_REGISTERED_=true
export _R_CHECK_OVERWRITE_REGISTERED_S3_METHODS_=true
export _R_CHECK_CODE_USAGE_WITH_ONLY_BASE_ATTACHED_=TRUE
export _R_CHECK_NATIVE_ROUTINE_REGISTRATION_=true
export _R_CHECK_FF_CALLS_=registration
export _R_CHECK_PRAGMAS_=true
export _R_CHECK_COMPILATION_FLAGS_=true
export _R_CHECK_R_DEPENDS_=true
export _R_CHECK_PACKAGES_USED_IN_TESTS_USE_SUBDIRS_=true
export _R_CHECK_SHLIB_OPENMP_FLAGS_=true
export _R_CHECK_CODE_ASSIGN_TO_GLOBALENV_=true
export _R_CHECK_CODE_DATA_INTO_GLOBALENV_=true
export _R_CHECK_PKG_SIZES_=true

export _R_CHECK_LIMIT_CORES_=true
#export _R_CHECK_LENGTH_1_CONDITION_ package:_R_CHECK_PACKAGE_NAME_,abort,verbose
export _R_S3_METHOD_LOOKUP_BASEENV_AFTER_GLOBALENV_=true
export _R_CHECK_AUTOCONF_=true
export _R_CHECK_THINGS_IN_CHECK_DIR_=true
export _R_CHECK_THINGS_IN_TEMP_DIR_=true
export _R_CHECK_THINGS_IN_TEMP_DIR_EXCLUDE_="^ompi"
export _R_CHECK_BASHISMS_=true
export _R_CHECK_ORPHANED_=true
export _R_CHECK_DEPENDS_ONLY_DATA_=true
export _R_CHECK_XREFS_PKGS_ARE_DECLARED_=true

yum install wget -y
yum install java-openjdk-devel -y
yum install libcxx-devel -y
yum install rsync -y
yum install openssl-devel -y

mkdir ~/.R
echo "MAKEFLAGS = -j 6" >> ~/.R/Makevars

cd
wget -c "https://stat.ethz.ch/R/daily/R-devel.tar.gz"
tar -zxvf R-devel.tar.gz
cd R-devel
tools/rsync-recommended
# check with https://www.stats.ox.ac.uk/pub/bdr/Rconfig/r-devel-linux-x86_64-fedora-clang
./configure \
  CC="clang" \
  CXX="clang++ -stdlib=libc++" \
  FC=gfortran \
  MAKEFLAGS="-j 6" \
  CFLAGS="-g -O3 -Wall -pedantic" \
  FFLAGS="-g -O2 -mtune=native -Wall -pedantic" \
  CXXFLAGS="-g -O3 -Wall -pedantic -frtti" \
  LDFLAGS="-L/usr/local/lib64" \
  JAVA_HOME=/usr/lib/jvm/java-11
make
make install

echo "options(repos = structure(c(CRAN = 'http://cran.rstudio.com')))" >> ~/.Rprofile
/root/R-devel/bin/R -e "install.packages('Rcpp')"

# replace the path with your path to openmp-exception-issue.cpp
/root/R-devel/bin/R -d valgrind -e "Rcpp::sourceCpp('/sdir/openmp-exception-issue.cpp'); that_cpp_func(100)"

Использование RcppThread

RcppThread также не работает. Рассмотрим следующий файл:

// openmp-exception-issue.cpp
#include <exception>
#include <stdexcept>
// [[Rcpp::depends(RcppThread)]]
#include <RcppThread.h>

// [[Rcpp::export()]]
double that_cpp_func(int const n_it){
  std::exception_ptr Ptr = nullptr;
  double out(0.);
  RcppThread::ThreadPool pool(4);

  for(int i = 0; i < n_it; ++i)
    pool.push([&](int const j) -> void {
        if(j > -1)
          throw std::runtime_error("boh :(");
        out += j; // ignore the race condition
      }, i);

  pool.join();

  return out;
}

Запуск примера, как и раньше, дает:

==139== Invalid read of size 8
==139==    at 0x71EC2DF: __cxa_end_catch (in /usr/lib64/libstdc++.so.6.0.28)
==139==    by 0x10B13351: RcppThread::ThreadPool::doJob(std::__1::function<void ()>&&) (ThreadPool.hpp:321)
==139==    by 0x10B13201: RcppThread::ThreadPool::startWorker()::{lambda()#1}::operator()() const (ThreadPool.hpp:304)
==139==    by 0x10B12F36: __invoke<(lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:279:27)> (type_traits:3899)
==139==    by 0x10B12F36: __thread_execute<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, (lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:279:27)> (thread:280)
==139==    by 0x10B12F36: void* std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, RcppThread::ThreadPool::startWorker()::{lambda()#1}> >(std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, RcppThread::ThreadPool::startWorker()::{lambda()#1}>) (thread:291)
==139==    by 0x53FA3F8: start_thread (in /usr/lib64/libpthread-2.32.so)
==139==    by 0x5514B52: clone (in /usr/lib64/libc-2.32.so)
==139==  Address 0x9151e90 is 96 bytes inside a block of size 144 free'd
==139==    at 0x483A9F5: free (vg_replace_malloc.c:538)
==139==    by 0xB6AE48A: __cxa_decrement_exception_refcount (in /usr/lib64/libc++abi.so.1.0)
==139==    by 0x10B13344: RcppThread::ThreadPool::doJob(std::__1::function<void ()>&&) (ThreadPool.hpp:320)
==139==    by 0x10B13201: RcppThread::ThreadPool::startWorker()::{lambda()#1}::operator()() const (ThreadPool.hpp:304)
==139==    by 0x10B12F36: __invoke<(lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:279:27)> (type_traits:3899)
==139==    by 0x10B12F36: __thread_execute<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, (lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:279:27)> (thread:280)
==139==    by 0x10B12F36: void* std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, RcppThread::ThreadPool::startWorker()::{lambda()#1}> >(std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, RcppThread::ThreadPool::startWorker()::{lambda()#1}>) (thread:291)
==139==    by 0x53FA3F8: start_thread (in /usr/lib64/libpthread-2.32.so)
==139==    by 0x5514B52: clone (in /usr/lib64/libc-2.32.so)
==139==  Block was alloc'd at
==139==    at 0x4839809: malloc (vg_replace_malloc.c:307)
==139==    by 0x71EC0C3: __cxa_allocate_exception (in /usr/lib64/libstdc++.so.6.0.28)
==139==    by 0x10B1240C: operator() (openmp-exception-issue.cpp:17)
==139==    by 0x10B1240C: operator() (ThreadPool.hpp:129)
==139==    by 0x10B1240C: __invoke<(lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:129:23) &> (type_traits:3899)
==139==    by 0x10B1240C: __call<(lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:129:23) &> (__functional_base:348)
==139==    by 0x10B1240C: operator() (functional:1557)
==139==    by 0x10B1240C: std::__1::__function::__func<void RcppThread::ThreadPool::push<that_cpp_func(int)::$_0, int&>(that_cpp_func(int)::$_0&&, int&)::{lambda()#1}, std::__1::allocator<{lambda()#1}>, void ()>::operator()() (functional:1731)
==139==    by 0x10B132FA: operator() (functional:1884)
==139==    by 0x10B132FA: operator() (functional:2556)
==139==    by 0x10B132FA: RcppThread::ThreadPool::doJob(std::__1::function<void ()>&&) (ThreadPool.hpp:317)
==139==    by 0x10B13201: RcppThread::ThreadPool::startWorker()::{lambda()#1}::operator()() const (ThreadPool.hpp:304)
==139==    by 0x10B12F36: __invoke<(lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:279:27)> (type_traits:3899)
==139==    by 0x10B12F36: __thread_execute<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, (lambda at /root/R-devel/library/RcppThread/include/RcppThread/ThreadPool.hpp:279:27)> (thread:280)
==139==    by 0x10B12F36: void* std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, RcppThread::ThreadPool::startWorker()::{lambda()#1}> >(std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct> >, RcppThread::ThreadPool::startWorker()::{lambda()#1}>) (thread:291)
==139==    by 0x53FA3F8: start_thread (in /usr/lib64/libpthread-2.32.so)
==139==    by 0x5514B52: clone (in /usr/lib64/libc-2.32.so)
...

Кажется, это та же ошибка:


person Benjamin Christoffersen    schedule 25.02.2021    source источник
comment
К сведению, проблема связана с этой проблемой Github.   -  person Benjamin Christoffersen    schedule 25.02.2021
comment
Отличный вопрос и то, что меня тоже интересует. Может быть, даже в более общем плане, как обрабатывать исключения в потоках? В книге параллелизм C++ в действии есть обсуждение, но это определенно непросто.   -  person thc    schedule 25.02.2021
comment
Не совсем то, что вы ищете, но библиотека RcppThread предлагает некоторые из этих функций. Например. безопасное прерывание потока.   -  person Joseph Wood    schedule 26.02.2021
comment
@thc Одна из проблем здесь заключается в том, что программирование только на C ++ отличается от программирования как с R, так и с C ++ и ограничениями R.   -  person Dirk Eddelbuettel    schedule 26.02.2021
comment
@JosephWood вы получаете ту же ошибку с библиотекой RcppThread. Их обработка исключений также основана на std::current_exception и также не работает.   -  person Benjamin Christoffersen    schedule 26.02.2021