highperfocused/bitcoin
1
0
Fork 0
mirror of https://github.com/bitcoin/bitcoin.git synced 2025-06-19 21:31:33 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor: Use appropriate thread constructor

Browse Source
This commit is contained in:
Hennadii Stepanov 2021-04-13 21:17:55 +03:00
parent 30e4448215
commit a508f718f3
No known key found for this signature in database
GPG Key ID: 410108112E7EA81F
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/init.cpp
View File

@ -1267,7 +1267,7 @@ bool AppInitMain(NodeContext& node, interfaces::BlockAndHeaderTipInfo* tip_info)
node.scheduler = std::make_unique<CScheduler>(); node.scheduler = std::make_unique<CScheduler>();
// Start the lightweight task scheduler thread // Start the lightweight task scheduler thread
node.scheduler->m_service_thread = std::thread([&] { util::TraceThread("scheduler", [&] { node.scheduler->serviceQueue(); }); }); node.scheduler->m_service_thread = std::thread(util::TraceThread, "scheduler", [&] { node.scheduler->serviceQueue(); });
// Gather some entropy once per minute. // Gather some entropy once per minute.
node.scheduler->scheduleEvery([]{ node.scheduler->scheduleEvery([]{

2
src/mapport.cpp
View File

@ -256,7 +256,7 @@ void StartThreadMapPort()
{ {
if (!g_mapport_thread.joinable()) { if (!g_mapport_thread.joinable()) {
assert(!g_mapport_interrupt); assert(!g_mapport_interrupt);
g_mapport_thread = std::thread(std::bind(&util::TraceThread, "mapport", &ThreadMapPort)); g_mapport_thread = std::thread(&util::TraceThread, "mapport", &ThreadMapPort);
} }
} }

2
src/test/util/setup_common.cpp
View File

@ -134,7 +134,7 @@ ChainTestingSetup::ChainTestingSetup(const std::string& chainName, const std::ve
// We have to run a scheduler thread to prevent ActivateBestChain // We have to run a scheduler thread to prevent ActivateBestChain
// from blocking due to queue overrun. // from blocking due to queue overrun.
m_node.scheduler = std::make_unique<CScheduler>(); m_node.scheduler = std::make_unique<CScheduler>();
m_node.scheduler->m_service_thread = std::thread([&] { util::TraceThread("scheduler", [&] { m_node.scheduler->serviceQueue(); }); }); m_node.scheduler->m_service_thread = std::thread(util::TraceThread, "scheduler", [&] { m_node.scheduler->serviceQueue(); });
GetMainSignals().RegisterBackgroundSignalScheduler(*m_node.scheduler); GetMainSignals().RegisterBackgroundSignalScheduler(*m_node.scheduler);
pblocktree.reset(new CBlockTreeDB(1 << 20, true)); pblocktree.reset(new CBlockTreeDB(1 << 20, true));