init: use std::thread for ThreadImport()
Mentioned in #19142, which removed the boost::interruption_point() in ThreadImport().
This commit is contained in:
parent
b33136b6ba
commit
83fd3a6d73
1 changed files with 5 additions and 3 deletions
|
@ -152,6 +152,8 @@ NODISCARD static bool CreatePidFile()
|
|||
|
||||
static std::unique_ptr<ECCVerifyHandle> globalVerifyHandle;
|
||||
|
||||
static std::thread g_load_block;
|
||||
|
||||
static boost::thread_group threadGroup;
|
||||
|
||||
void Interrupt(NodeContext& node)
|
||||
|
@ -214,8 +216,9 @@ void Shutdown(NodeContext& node)
|
|||
StopTorControl();
|
||||
|
||||
// After everything has been shut down, but before things get flushed, stop the
|
||||
// CScheduler/checkqueue threadGroup
|
||||
// CScheduler/checkqueue, threadGroup and load block thread.
|
||||
if (node.scheduler) node.scheduler->stop();
|
||||
if (g_load_block.joinable()) g_load_block.join();
|
||||
threadGroup.interrupt_all();
|
||||
threadGroup.join_all();
|
||||
|
||||
|
@ -680,7 +683,6 @@ static void CleanupBlockRevFiles()
|
|||
static void ThreadImport(ChainstateManager& chainman, std::vector<fs::path> vImportFiles)
|
||||
{
|
||||
const CChainParams& chainparams = Params();
|
||||
util::ThreadRename("loadblk");
|
||||
ScheduleBatchPriority();
|
||||
|
||||
{
|
||||
|
@ -1842,7 +1844,7 @@ bool AppInitMain(const util::Ref& context, NodeContext& node)
|
|||
vImportFiles.push_back(strFile);
|
||||
}
|
||||
|
||||
threadGroup.create_thread([=, &chainman] { ThreadImport(chainman, vImportFiles); });
|
||||
g_load_block = std::thread(&TraceThread<std::function<void()>>, "loadblk", [=, &chainman]{ ThreadImport(chainman, vImportFiles); });
|
||||
|
||||
// Wait for genesis block to be processed
|
||||
{
|
||||
|
|
Loading…
Reference in a new issue