// Copyright 2020 The Division Authors. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // https://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // Author dietoad@gmail.com && firedtoad@gmail.com #include #include #include #include #include void worker_thread() { boost::asio::io_service io_service; std::vector vi; vi.reserve(100000); for (auto i = 1; i < 100000; i++) { auto &timer = vi.emplace_back(io_service); timer.expires_from_now(boost::posix_time::millisec(i * 1)); timer.async_wait( [](boost::system::error_code) { // std::cout << __PRETTY_FUNCTION__ << '\n'; }); } io_service.run(); } int main(int argc, char **argv) { // std::vector> vecThread; // for (auto i = 0; i < 4; i++) // { // vecThread.emplace_back(std::make_unique(worker_thread)); // } // for (auto &it : vecThread) // { // it->join(); // } return 0; }