84 lines
3.1 KiB
C++
84 lines
3.1 KiB
C++
|
// Fig. 17.11: CooperativeCancelation.cpp
|
||
|
|
// Using a std::jthread's built-in stop_source
|
||
|
|
// to request that the std::jthread stop executing.
|
||
|
|
#include <chrono>
|
||
|
|
#include <fmt/format.h>
|
||
|
|
#include <iostream>
|
||
|
|
#include <mutex>
|
||
|
|
#include <random>
|
||
|
|
#include <sstream>
|
||
|
|
#include <string>
|
||
|
|
#include <string_view>
|
||
|
|
#include <thread>
|
||
|
|
|
||
|
|
// get current thread's ID as a string
|
||
|
|
std::string id() {
|
||
|
|
std::ostringstream out;
|
||
|
|
out << std::this_thread::get_id();
|
||
|
|
return out.str();
|
||
|
|
}
|
||
|
|
|
||
|
|
int main() {
|
||
|
|
// each printTask iterates until a stop is requested by another thread
|
||
|
|
auto printTask{
|
||
|
|
[&](std::stop_token token, std::string name) {
|
||
|
|
// set up random-number generation
|
||
|
|
std::random_device rd;
|
||
|
|
std::default_random_engine engine{rd()};
|
||
|
|
std::uniform_int_distribution ints{500, 1000};
|
||
|
|
|
||
|
|
// register a function to call when a stop is requested
|
||
|
|
std::stop_callback callback(token, [&]() {
|
||
|
|
std::cout << fmt::format(
|
||
|
|
"{} told to stop by thread with id {}\n", name, id());
|
||
|
|
});
|
||
|
|
|
||
|
|
while (!token.stop_requested()) { // run until stop requested
|
||
|
|
auto sleepTime{std::chrono::milliseconds{ints(engine)}};
|
||
|
|
|
||
|
|
std::cout << fmt::format(
|
||
|
|
"{} (id: {}) going to sleep for {} ms\n",
|
||
|
|
name, id(), sleepTime.count());
|
||
|
|
|
||
|
|
// put thread to sleep for sleepTime milliseconds
|
||
|
|
std::this_thread::sleep_for(sleepTime);
|
||
|
|
|
||
|
|
// show that task woke up
|
||
|
|
std::cout << fmt::format("{} working.\n", name);
|
||
|
|
}
|
||
|
|
|
||
|
|
std::cout << fmt::format("{} terminating.\n", name);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
std::cout << fmt::format("MAIN (id: {}) STARTING TASKS\n", id());
|
||
|
|
|
||
|
|
// create two jthreads that each call printTask with a string argument
|
||
|
|
std::jthread task1{printTask, "Task 1"};
|
||
|
|
std::jthread task2{printTask, "Task 2"};
|
||
|
|
|
||
|
|
// put main thread to sleep for 2 seconds
|
||
|
|
std::cout << "\nMAIN GOING TO SLEEP FOR 2 SECONDS\n\n";
|
||
|
|
std::this_thread::sleep_for(std::chrono::seconds{2});
|
||
|
|
|
||
|
|
std::cout << fmt::format("\nMAIN (id: {}) ENDS\n\n", id());
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
/************************************************************************
|
||
|
|
* (C) Copyright 1992-2022 by Deitel & Associates, Inc. and *
|
||
|
|
* Pearson Education, Inc. All Rights Reserved. *
|
||
|
|
* *
|
||
|
|
* DISCLAIMER: The authors and publisher of this book have used their *
|
||
|
|
* best efforts in preparing the book. These efforts include the *
|
||
|
|
* development, research, and testing of the theories and programs *
|
||
|
|
* to determine their effectiveness. The authors and publisher make *
|
||
|
|
* no warranty of any kind, expressed or implied, with regard to these *
|
||
|
|
* programs or to the documentation contained in these books. The *
|
||
|
|
* authors and publisher shall not be liable in any event for *
|
||
|
|
* incidental or consequential damages in connection with, or arising *
|
||
|
|
* out of, the furnishing, performance, or use of these programs. *
|
||
|
|
***********************************************************************/
|
||
|
|
|