thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-28 18:42:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix code style

Browse Source
This commit is contained in:
Vxider 2019-12-13 16:42:08 +08:00
parent 49065a6348
commit ec784150b3
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dbms/src/DataStreams/copyData.cpp
View File

@ -63,7 +63,7 @@ void copyDataImpl(BlockInputStreams & froms, BlockOutputStreams & tos)
threads.reserve(froms.size());
for (size_t i = 0; i < froms.size(); i++)
{
threads.emplace_back([from = froms.at(i), to = tos.at(i)]()
threads.emplace_back([from = froms.at(i), to = tos.at(i)]()
{
from->readPrefix();
to->writePrefix();
@ -79,13 +79,13 @@ void copyDataImpl(BlockInputStreams & froms, BlockOutputStreams & tos)
else
{
ConcurrentBoundedQueue<Block> queue(froms.size());
ThreadFromGlobalPool from_threads([&]()
ThreadFromGlobalPool from_threads([&]()
{
std::vector<ThreadFromGlobalPool> from_threads_;
from_threads_.reserve(froms.size());
for (auto & from : froms)
{
from_threads_.emplace_back([&queue, from]()
from_threads_.emplace_back([&queue, from]()
{
from->readPrefix();
while (Block block = from->read())
@ -101,7 +101,7 @@ void copyDataImpl(BlockInputStreams & froms, BlockOutputStreams & tos)
std::vector<ThreadFromGlobalPool> to_threads;
for (auto & to : tos)
{
to_threads.emplace_back([&queue, to]()
to_threads.emplace_back([&queue, to]()
{
to->writePrefix();
Block block;