Method TestThreaded

cpp/src/arrow/csv/column_decoder_test.cc:177–191

  }

  void TestThreaded() {
#ifndef ARROW_ENABLE_THREADING
    GTEST_SKIP() << "Test requires threading support";
#endif
    constexpr int NITERS = 10;
    auto type = int32();
    MakeDecoder(type);

    RunThreadsAndJoin(
        [&](int thread_id) {
          AssertChunk({"4", "5", std::to_string(thread_id)},
                      ArrayFromJSON(type, "[null, null, null]"));
        },
        NITERS);
  }
};

TEST_F(NullColumnDecoderTest, NullType) { this->TestNullType(); }