C++20: Bir iş parçacığını geri aramalarla işbirliği içinde kesme
Hatırlatma olarak, “Yazılım Geliştirme: C++20'de Bir İş Parçacığının İşbirliğine Dayalı Olarak Askıya Alınması” adlı önceki yazımda aşağıdaki programı tanıtmıştım.
Duyuru
Rainer Grimm uzun yıllardır yazılım mimarı, ekip ve eğitim yöneticisi olarak çalışmaktadır. C++, Python ve Haskell programlama dilleri üzerine makaleler yazmaktan hoşlanıyor, aynı zamanda özel konferanslarda sık sık konuşmaktan da hoşlanıyor. Modern C++ adlı blogunda C++ tutkusunu yoğun bir şekilde ele alıyor.
// invokeCallback.cpp
#include <chrono>
#include <iostream>
#include <thread>
#include <vector>
using namespace::std::literals;
auto func = [](std::stop_token stoken) { // (1)
int counter{0};
auto thread_id = std::this_thread::get_id();
std::stop_callback callBack(stoken,
[&counter, thread_id] { // (2)
std::cout << "Thread id: " << thread_id
<< "; counter: " << counter << 'n';
});
while (counter < 10) {
std::this_thread::sleep_for(0.2s);
++counter;
}
};
int main() {
std::cout << 'n';
std::vector<std::jthread> vecThreads(10);
for(auto& thr: vecThreads) thr = std::jthread(func);
std::this_thread::sleep_for(1s); // (3)
for(auto& thr: vecThreads) thr.request_stop(); // (4)
std::cout << 'n';
}
On iş parçacığının her biri Lambda işlevini çağırır func (1 Yukarı. Geri arama (2) iş parçacığı kimliğini ve sayacı görüntüler. Ana iş parçacığı (3) bir saniye uyuduğundan ve alt iş parçacığı da uyuduğundan, geri aramalar çağrıldığında sayaç 4'tür. Arama thr.request_stop() her iş parçacığında geri aramayı etkinleştirin.
Son yazımda cevabını bulamadığım bir soru:
Geri arama nerede yapılır?
THE std::stop_callbackYapıcı, geri çağırma işlevini kaydeder. std::stop_tokenortak tarafından temsil edilen std::stop_source veriyor. Bu geri çağırma işlevi hem iş parçacığında hem de iş parçacığında çağrılır. request_stop() çağrılarda veya onu çağıran başlıkta std::stop_callback inşa edilmiş. Dosyayı kaydetmeden önce durmanız istenirse std::stop_callback oluşursa, dosyayı içeren iş parçacığında geri arama çağrılır std::stop_callback inşa edilmiş. Aksi takdirde geri arama o iş parçacığında çağrılacaktır. request_stop Aramalar. Çağrı yapıldı request_stop() dosyayı içeren iş parçacığı yürütüldükten sonra std::stop_callback yerleşik olarak kayıtlı geri arama asla çağrılmaz.
Aynı konuyu kullanan bir veya daha fazla iş parçacığı için birden fazla geri arama yapabilirsiniz std::stop_token kaydetmek için. C++ standardı bunların yürütülme sırasına ilişkin hiçbir garanti vermez.
Bir hatırlatmadan daha fazlası
// invokeCallbacks.cpp
#include <chrono>
#include <iostream>
#include <thread>
using namespace std::literals;
void func(std::stop_token stopToken) {
std::this_thread::sleep_for(100ms);
for (int i = 0; i <= 9; ++i) {
std::stop_callback cb(stopToken, { std::cout << i; });
}
std::cout << 'n';
}
int main() {
std::cout << 'n';
std::jthread thr1 = std::jthread(func);
std::jthread thr2 = std::jthread(func);
thr1.request_stop();
thr2.request_stop();
std::cout << 'n';
}
Sinyal göndermek için genel bir mekanizma
Çift std::stop_source VE std::stop_token bir sinyal göndermek için genel bir mekanizma olarak görülebilir. Böylece std::stop_token kopyalandığında, sinyali bir şey yapan herhangi bir varlığa gönderebilirsiniz. Aşağıdaki örnekte kullanıyorum std::async, std:
romise, std::thread VE std::jthread farklı kombinasyonlarda.
// signalStopRequests.cpp
#include <iostream>
#include <thread>
#include <future>
using namespace std::literals;
void function1(std::stop_token stopToken, const std::string& str){
std::this_thread::sleep_for(1s);
if (stopToken.stop_requested()) std::cout << str
<< ": Stop requestedn";
}
void function2(std:romise<void> prom,
std::stop_token stopToken, const std::string& str) {
std::this_thread::sleep_for(1s);
std::stop_callback callBack(stopToken, [&str] {
std::cout << str << ": Stop requestedn";
});
prom.set_value();
}
int main() {
std::cout << 'n';
std::stop_source stopSource; // (1)
std::stop_token stopToken =
std::stop_token(stopSource.get_token()); // (2)
std::thread thr1 =
std::thread(function1, stopToken, "std::thread"); // (3)
std::jthread jthr =
std::jthread(function1, stopToken, "std::jthread"); // (4)
auto fut1 = std::async([stopToken] { // (5)
std::this_thread::sleep_for(1s);
if (stopToken.stop_requested()) std::cout
<< "std::async: Stop requestedn";
});
std:romise<void> prom; // (6)
auto fut2 = prom.get_future();
std::thread thr2(function2, std::move(prom),
stopToken, "std:romise");
stopSource.request_stop(); // (7)
if (stopToken.stop_requested())
std::cout << "main: Stop requestedn"; // (8)
thr1.join();
thr2.join();
std::cout << 'n';
}
sayesinde stopSource (1) Bunu yapabilirim stopToken (2) çalışan her varlık için kullanın, ör. B. std::thread (3), std::jthread (4), std::async (5) veya std:romise (6). A std::stop_token kopyalamak ucuzdur. (7) çözer stopSource.request_stop dıştan. Ayrıca ana kablo (8) sinyali alır. Bu örnekte kullanıyorum std::jthread. std::jthread VE std::condition_variable_any işbirliği kesintilerini daha rahat bir şekilde ele almak için açık üye işlevlerine sahiptir. Daha fazla bilgi “C++20 ile geliştirilmiş bir iş parçacığı” makalesinde bulunabilir.
Sıradaki ne?
Önümüzdeki birkaç hafta boyunca yazmaya ara vereceğim. Bundan sonra C++23 kullanmaya geri döneceğim ve ilk kez C++26 ile devam edeceğim.
(kendim)
C++20: Bir iş parçacığını geri aramalarla işbirliği içinde kesme
Hatırlatma olarak, “Yazılım Geliştirme: C++20'de Bir İş Parçacığının İşbirliğine Dayalı Olarak Askıya Alınması” adlı önceki yazımda aşağıdaki programı tanıtmıştım.
Duyuru
Rainer Grimm uzun yıllardır yazılım mimarı, ekip ve eğitim yöneticisi olarak çalışmaktadır. C++, Python ve Haskell programlama dilleri üzerine makaleler yazmaktan hoşlanıyor, aynı zamanda özel konferanslarda sık sık konuşmaktan da hoşlanıyor. Modern C++ adlı blogunda C++ tutkusunu yoğun bir şekilde ele alıyor.
// invokeCallback.cpp
#include <chrono>
#include <iostream>
#include <thread>
#include <vector>
using namespace::std::literals;
auto func = [](std::stop_token stoken) { // (1)
int counter{0};
auto thread_id = std::this_thread::get_id();
std::stop_callback callBack(stoken,
[&counter, thread_id] { // (2)
std::cout << "Thread id: " << thread_id
<< "; counter: " << counter << 'n';
});
while (counter < 10) {
std::this_thread::sleep_for(0.2s);
++counter;
}
};
int main() {
std::cout << 'n';
std::vector<std::jthread> vecThreads(10);
for(auto& thr: vecThreads) thr = std::jthread(func);
std::this_thread::sleep_for(1s); // (3)
for(auto& thr: vecThreads) thr.request_stop(); // (4)
std::cout << 'n';
}
On iş parçacığının her biri Lambda işlevini çağırır func (1 Yukarı. Geri arama (2) iş parçacığı kimliğini ve sayacı görüntüler. Ana iş parçacığı (3) bir saniye uyuduğundan ve alt iş parçacığı da uyuduğundan, geri aramalar çağrıldığında sayaç 4'tür. Arama thr.request_stop() her iş parçacığında geri aramayı etkinleştirin.
Son yazımda cevabını bulamadığım bir soru:
Geri arama nerede yapılır?
THE std::stop_callbackYapıcı, geri çağırma işlevini kaydeder. std::stop_tokenortak tarafından temsil edilen std::stop_source veriyor. Bu geri çağırma işlevi hem iş parçacığında hem de iş parçacığında çağrılır. request_stop() çağrılarda veya onu çağıran başlıkta std::stop_callback inşa edilmiş. Dosyayı kaydetmeden önce durmanız istenirse std::stop_callback oluşursa, dosyayı içeren iş parçacığında geri arama çağrılır std::stop_callback inşa edilmiş. Aksi takdirde geri arama o iş parçacığında çağrılacaktır. request_stop Aramalar. Çağrı yapıldı request_stop() dosyayı içeren iş parçacığı yürütüldükten sonra std::stop_callback yerleşik olarak kayıtlı geri arama asla çağrılmaz.
Aynı konuyu kullanan bir veya daha fazla iş parçacığı için birden fazla geri arama yapabilirsiniz std::stop_token kaydetmek için. C++ standardı bunların yürütülme sırasına ilişkin hiçbir garanti vermez.
Bir hatırlatmadan daha fazlası
// invokeCallbacks.cpp
#include <chrono>
#include <iostream>
#include <thread>
using namespace std::literals;
void func(std::stop_token stopToken) {
std::this_thread::sleep_for(100ms);
for (int i = 0; i <= 9; ++i) {
std::stop_callback cb(stopToken, { std::cout << i; });
}
std::cout << 'n';
}
int main() {
std::cout << 'n';
std::jthread thr1 = std::jthread(func);
std::jthread thr2 = std::jthread(func);
thr1.request_stop();
thr2.request_stop();
std::cout << 'n';
}
Sinyal göndermek için genel bir mekanizma
Çift std::stop_source VE std::stop_token bir sinyal göndermek için genel bir mekanizma olarak görülebilir. Böylece std::stop_token kopyalandığında, sinyali bir şey yapan herhangi bir varlığa gönderebilirsiniz. Aşağıdaki örnekte kullanıyorum std::async, std:
romise, std::thread VE std::jthread farklı kombinasyonlarda.// signalStopRequests.cpp
#include <iostream>
#include <thread>
#include <future>
using namespace std::literals;
void function1(std::stop_token stopToken, const std::string& str){
std::this_thread::sleep_for(1s);
if (stopToken.stop_requested()) std::cout << str
<< ": Stop requestedn";
}
void function2(std:
romise<void> prom, std::stop_token stopToken, const std::string& str) {
std::this_thread::sleep_for(1s);
std::stop_callback callBack(stopToken, [&str] {
std::cout << str << ": Stop requestedn";
});
prom.set_value();
}
int main() {
std::cout << 'n';
std::stop_source stopSource; // (1)
std::stop_token stopToken =
std::stop_token(stopSource.get_token()); // (2)
std::thread thr1 =
std::thread(function1, stopToken, "std::thread"); // (3)
std::jthread jthr =
std::jthread(function1, stopToken, "std::jthread"); // (4)
auto fut1 = std::async([stopToken] { // (5)
std::this_thread::sleep_for(1s);
if (stopToken.stop_requested()) std::cout
<< "std::async: Stop requestedn";
});
std:
romise<void> prom; // (6) auto fut2 = prom.get_future();
std::thread thr2(function2, std::move(prom),
stopToken, "std:
romise");
stopSource.request_stop(); // (7)
if (stopToken.stop_requested())
std::cout << "main: Stop requestedn"; // (8)
thr1.join();
thr2.join();
std::cout << 'n';
}
sayesinde stopSource (1) Bunu yapabilirim stopToken (2) çalışan her varlık için kullanın, ör. B. std::thread (3), std::jthread (4), std::async (5) veya std:
romise (6). A std::stop_token kopyalamak ucuzdur. (7) çözer stopSource.request_stop dıştan. Ayrıca ana kablo (8) sinyali alır. Bu örnekte kullanıyorum std::jthread. std::jthread VE std::condition_variable_any işbirliği kesintilerini daha rahat bir şekilde ele almak için açık üye işlevlerine sahiptir. Daha fazla bilgi “C++20 ile geliştirilmiş bir iş parçacığı” makalesinde bulunabilir.Sıradaki ne?
Önümüzdeki birkaç hafta boyunca yazmaya ara vereceğim. Bundan sonra C++23 kullanmaya geri döneceğim ve ilk kez C++26 ile devam edeceğim.
(kendim)