• Najnowsze pytania
  • Bez odpowiedzi
  • Zadaj pytanie
  • Kategorie
  • Tagi
  • Zdobyte punkty
  • Ekipa ninja
  • IRC
  • FAQ
  • Regulamin
  • Książki warte uwagi

[C++] Wielowątkowość - funkcja z dwoma wątkami zwracająca wartość gdy jeden z wątków się wykona

VPS Starter Arubacloud
+1 głos
315 wizyt
pytanie zadane 21 stycznia 2018 w C i C++ przez niezalogowany

Zadanie: Wykonaj funkcję, która poczeka np 5s na podanie wartości. Jeżeli ta nie zostanie wczytana program ma wykonywać się dalej.

Problem został zaczerpnięty z tego tematu: link

Nie znam jeszcze zbyt wielu zagadnień dot. wielowątkowości (tak właściwe kojarzę tylko podstawowe std::thread), ale udało mi się napisać coś takiego:

#include <iostream>
#include <thread>
#include <chrono>

template <typename T> 
bool read_or_wait(T& var, std::chrono::seconds wait_time);

int main()
{
	int number = 7;

	using namespace std::chrono_literals;
	std::cout << "Podaj liczbę: ";

	std::cout << (
		read_or_wait(number, 4s)
		? "Podałeś wartość: "
		: "Za wolno :P \nWybrałem za Ciebie wartość: ")
		<< number << "\n";

}

template <typename T>
bool read_or_wait(T& var, std::chrono::seconds wait_time)
{
	bool value_is_read = false; // mutex? atomic?

	auto read = [&var, &value_is_read]
	{
		std::cin >> var;
		value_is_read = true;
	};

	auto wait = [&wait_time, &value_is_read]
	{
		auto begin = std::chrono::high_resolution_clock::now();
		auto end = begin + wait_time;
		do {
			std::this_thread::yield(); // nie chcę usypiać całego wątku, bo nie wiem kiedy zostanie pobrana wartosć
			if (value_is_read) // jeżeli wartość zostanie wczytana to przerwanie funkcji wait()
				return;
		} while (std::chrono::high_resolution_clock::now() < end);
	};

	std::thread reading(read);
	std::thread waiting(wait);

	reading.detach(); // nie chcę czekać na wywołanie tej funkcji gdy czas na podanie wartości się skończył
	waiting.join();

	return value_is_read;
}

Funkcja działa tak jak chciałem, ale czy takie rozwiązanie jest bezpieczne? Co się dzieje z funkcją read na odłączonym wątku gdy funkcja read_or_wait zwróci wartość? Jak wykonać to lepiej?

2 odpowiedzi

+2 głosów
odpowiedź 21 stycznia 2018 przez mokrowski Mędrzec (155,460 p.)
wybrane 21 stycznia 2018
 
Najlepsza
#include <future>
#include <iostream>
#include <chrono>

#ifdef __has_include
#    if __has_include(<optional>)
#        include <optiona>
         using std::optional;
#    elif __has_include(<experimental/optional>)
#        include <experimental/optional>
         using std::experimental::optional;
#    else
#        error "Missing <optional>"
#    endif
#endif

optional<int> readValue(std::chrono::seconds waitTime) {
    std::promise<int> valuePromise;
    auto ftr = valuePromise.get_future();
    std::thread([&valuePromise]{
            int value;
            std::cin >> value;
            valuePromise.set_value(value);
    }).detach();

    std::future_status status = ftr.wait_for(waitTime);
    if((status == std::future_status::deferred) || (status == std::future_status::timeout)) {
        std::cout << "Czas minął" << std::endl;
        return {};
    }
    return optional<int>(ftr.get());
}

int main() {
    using namespace std::chrono_literals;
    std::cout << "Podaj wartość całkowitą w ciągu 4 sekund: ";
    auto val = readValue(4s);
    std::cout << "Powrót do main()" << std::endl;
    if(val) {
        std::cout << "Podałeś: " << *val << std::endl;
    } else {
        std::cout << "Hmm... słaby refleks. 4 sekundy to zbyt szybko?" << std::endl;
    }
}

Podaję raczej w trybie edukacyjnym.... Problem który podałeś, rozwiązuj funkcjami asynchronicznego odczytu dedykowanymi dla danego systemu. 

PS. Jak byś się nie "gimnastykował", problemu blokującego std::cin nie obejdziesz środkami biblioteki standardowej. Dodatkowo masz tak w swoim kodzie jak i tu, wiszący odłączony wątek.

+2 głosów
odpowiedź 21 stycznia 2018 przez monika90 Pasjonat (22,940 p.)
edycja 21 stycznia 2018 przez monika90

Problem jest taki, że zmienne number i value_is_read są jednocześnie czytane i zapisywane przez więcej niż jeden wątek. A nawet gorzej, wątek wykonujący lambdę read może spróbować zapisać coś do tych zmiennych gdy one już nie istnieją.

Może spróbuj zrobić to bez wielowątkowość. Np. czytając klawiaturę za pomocą funkcji kbhit i getch z <conio.h> - to będzie o wiele łatwiejsze.

Podobne pytania

+1 głos
4 odpowiedzi 401 wizyt
pytanie zadane 21 czerwca 2017 w C i C++ przez wanttobeanengineer Obywatel (1,120 p.)
0 głosów
3 odpowiedzi 904 wizyt
pytanie zadane 21 kwietnia 2019 w Java przez poldeeek Mądrala (5,980 p.)
0 głosów
1 odpowiedź 169 wizyt
pytanie zadane 29 grudnia 2018 w Java przez ILikeJava Obywatel (1,230 p.)

92,454 zapytań

141,262 odpowiedzi

319,089 komentarzy

61,854 pasjonatów

Motyw:

Akcja Pajacyk

Pajacyk od wielu lat dożywia dzieci. Pomóż klikając w zielony brzuszek na stronie. Dziękujemy! ♡

Oto polecana książka warta uwagi.
Pełną listę książek znajdziesz tutaj.

Akademia Sekuraka

Akademia Sekuraka 2024 zapewnia dostęp do minimum 15 szkoleń online z bezpieczeństwa IT oraz dostęp także do materiałów z edycji Sekurak Academy z roku 2023!

Przy zakupie możecie skorzystać z kodu: pasja-akademia - użyjcie go w koszyku, a uzyskacie rabat -30% na bilety w wersji "Standard"! Więcej informacji na temat akademii 2024 znajdziecie tutaj. Dziękujemy ekipie Sekuraka za taką fajną zniżkę dla wszystkich Pasjonatów!

Akademia Sekuraka

Niedawno wystartował dodruk tej świetnej, rozchwytywanej książki (około 940 stron). Mamy dla Was kod: pasja (wpiszcie go w koszyku), dzięki któremu otrzymujemy 10% zniżki - dziękujemy zaprzyjaźnionej ekipie Sekuraka za taki bonus dla Pasjonatów! Książka to pierwszy tom z serii o ITsec, który łagodnie wprowadzi w świat bezpieczeństwa IT każdą osobę - warto, polecamy!

...