Root.cz  »  Blogy  »  Zmatení (programovacích) jazyků  »  Nevtíravý paralelismus

Nevtíravý paralelismus

31. 10. 2011 7:18 (aktualizováno) zboj

Není třeba zdůrazňovat, že asynchronní provádění kódu ve více vláknech je mnohdy užitečné. Jedním z případů, kdy se velmi často používá, je síťová komunikace. Mějme tyto funkce:

std::string download(const std::string&);
void process(const std::string&);

První funkce dostane URL a vrátí jeho obsah jako řetězec. Druhá s výsledkem něco provede. Použití těchto funkcí je zřejmé.

auto s1 = download(url1);
auto s2 = download(url2);
process(s1 + s2);

Zřejmá je i nevýhoda. Funkce download čeká, až se naváže spojení a stáhnou data. Kód je tedy prováděn sekvenčně. Ideálně bychom chtěli něco jako:

auto s1 = ASYNC(download(url1));
auto s2 = ASYNC(download(url2));
process(s1 + s2);

První řádek zavolá funkci download, ale asynchronně, tj. bez zablokování aktuálního vlákna. Tím se hned provede i druhý řádek, který zahájí stahování z druhé adresy. Na třetím řádku naopak chceme aktuální vlákno zablokovat, protože pracujeme s výsledky funkce download, na něž vzhledem k relativně malé rychlosti síťové komunikace musíme počkat.

Je možné napsat v C++ takové makro? Odpověď zní ano, ale… Je třeba použít šablony, přetěžování operátorů a funktory a z C++11 auto, lambda výrazy, future a decltype. Pokud má makro fungovat i v clangu, jenž nemá lambda výrazy podle standardu, musíme mít navíc dvě verze kódu.

Samotné makro je poměrně jednoduché:

#define ASYNC(x) AsyncResult<decltype(x)>(LAMBDA(x))

Použijeme třídu AsyncResult, která dostane lambda výraz (C++11) nebo blok (clang). Od rozdílu mezi překladači nás odstíní makro LAMBDA.

#ifdef __BLOCKS__
#define LAMBDA(x) BlockWrapper<decltype(x)>(^{ return x; })
#else
#define LAMBDA(x) [=]()->decltype(x){ return x; }
#endif

Protože potřebujeme objekt typu std::function<T()>, tedy funktor, pro clang použijeme pomocnou třídu BlockWrapper, jejíž implementace je zřejmá (přetíží operátor ()). Podporuje-li překladač lambda výrazy podle standardu, použijeme přímo je.

Zbývá třída AsyncResult:

template <typename T> class AsyncResult {
private:
__std::future<T> fut;
public:
#ifdef __BLOCKS__
__AsyncResult(BlockWrapper<T>&& bw) : fut(std::async(std::launch::async, bw)) {}
#else
__AsyncResult(std::function<T()>&& f) : fut(std::async(std::launch::async, f)) {}
#endif
__AsyncResult(AsyncResult&& r) : fut(std::move(r.fut)) {}
__operator T() { return fut.get(); }
__T operator+(T n);
};

template <typename T> T AsyncResult<T>::operator+(T n) { return fut.get() + n; }
template <> std::string AsyncResult<std::string>::operator+(std::string n) {
__std::stringstream ss;
__ss << fut.get() << n;
__return ss.str();
}

Použití třídy stringstream je nutné ve Visual Studiu (v clangu funguje operátor +, ale stringstream je samozřejmě univerzální). Jak je vidět, třída AsyncResult používá std::future. Tím je umožněno asynchronní provedení kódu (přičemž konkrétní implementace je na standardní knihovně). Až výsledek potřebujeme, použije se metoda get v přetíženém operátoru + nebo přetypování (ta naopak zaručí, že aktuální vlákno počká na dokončení asynchronního kódu).

Uvedený příklad tedy spustí dvě nová vlákna, která nezávisle na sobě stáhnout obsah z URL. Zároveň je zajištěna synchronizace s aktuálním vláknem při použití výsledků. Makro ASYNC je „nevtíravé“ (nonintrusive), potřebujeme-li přeložit kód překladačem bez podpory C++11, jednoduše deklarujeme #define ASYNC(x) x.

Sdílet

Přidat názor
Přidat názor

zboj

Autor se zabývá vývojem kompilátorů a knihoven pro objektově-orientované programovací jazyky.

Nejčtenější články autora

  1. Co zlepšit na českých VŠ?

    Přečteno 37 774×

  2. Potřebují programátoři VŠ?

    Přečteno 26 420×

  3. Proč je Java za zenitem

    Přečteno 24 932×

  4. Jaký jazyk jako první?

    Přečteno 21 278×

  5. Potřebujeme vynikající programátory?

    Přečteno 18 932×

Dále u nás najdete

Kolik bude stát snížení záloh OSVČ? Každý tvrdí něco jiného

Proč přichází éra suverénních datových center?

Agentní AI nakupování přichází. I do Česka

Po Black Friday přichází Cyber Monday. Jaká je jeho historie?

Množství údajů dle nařízení vlády k JMHZ mnohé překvapí

Zdravotní a sociální pojištění 2026 u OSVČ: Opět výrazný růst záloh

V roce 2026 nevzrostou OSVČ jen odvody. Co dál se mění?

Změny v sociálním pojištění v roce 2026 v oblasti zaměstnávání

Osvědčený recept na linecké. Zásadní je správný poměr surovin

V Praze jídlo rozváží roboti. „Kurýři nebudou mít co žrát,“ zní na sítích

Babišův střet zájmů potvrdil soud, Agrofert už přišel o stovky milionů

Zahraniční cestovní náhrady v roce 2026. 0smnást nových sazeb

Příběh fyzioterapeuta, který léčí závratě a jezdí k lidem domů

Bionáplast pomáhá s hojením bércových vředů

Nádor slinivky se ohlásil nafouklým břichem, pak přišla rychlá operace

HP chce propouštět a šetřit, argumentuje AI

Je mi dobře, prášek si nevezmu. Lidé si nerozumně mění léčbu

Chytré bio-nálepky změří infekci, hormony i markery rakoviny

V ČR vznikají čtyři velká datacentra pro AI

Kubík musel na mimotělní oběh hned po porodu