testInterrupt.cpp

#include <Rcpp.h>
#include <thread>
using namespace Rcpp;

//[[Rcpp::export]]
void testInterrupt(const int jsize, bool verbose, const int out_index = 0) {
  std::ostream* pout;
  if (out_index == 0) pout = &Rcout;
  else if (out_index == 1) pout = &std::cout;
  else throw std::invalid_argument("out");
  std::ostream& out(*pout);
  bool is_interrupted = false;
  {
    for(int i = 0;i < 10;i++) {
      for(int j = 0;j < jsize;j++) {
        {
          if (verbose) {
            out << ".";
            out.flush();
          }
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(5000 / jsize));
      }
      {
        out << std::endl;
        try {
          checkUserInterrupt();
        } catch (...) {
          std::cerr << "setting is_interrupted" << std::endl;
          is_interrupted = true;
        }
      }
      if (is_interrupted) {
        break;
      }
    }
  }
  if (is_interrupted) {
    std::cerr << "Interrupted!" << std::endl;
    throw Rcpp::internal::InterruptedException();
  }
}