Vlákna - synchronizace – C / C++ – Fórum – Programujte.com

Zdravím,

řeším klasický problém producent - konzument. Producent zapisuje data do fronty ( mám LIFO ) a konzumenti z ní vybírají... Jde mi o to, že vím jak synchronizovat takovouto úlohu, pokud znám předem velikost fronty (pomocí dvou semaforů), ale co když tu velikost neznám a fronta se mi dynamicky zvětšuje?

sak zamkni mutex, zjisti velikost fronty, odeber prvek, odemkni...   u pridavajiciho threadu zase zamknout, pridat, odemknout---  tak aby data zustavaly zamceny co nejkratsi dobu

#2 KIIV
zatím to dělám tak, že přidám prvek do fronty -> zvýším hodnotu semaforu -> konzument čeká na semaforu -> zpracuje prvek z fronty a zase hodnotu semaforu sníží... jenže pak mám problém, že někdy (zhruba 1/10 pokusů) se mi neukončí nějaká vlákna (prostě zůstanou viset na semaforu v konzumentovi) ... ( samozřejmě zamykám mutexama přidání a odebrání prvku z fronty... )

Asi budeš muset ukázat kód, nedovedu si představit, jak se to děje jen někdy. Pokud konzumenti čekají na semaforu, tak ho samozřejmě musíš pro všechny zvednout, aby se probrali.

producent()
{
    while ((prvek = produkuj()) != null)
    {
        put(prvek);
        sem++;
    }

    sem += pocetkonzumentu;
}


konzument()
{
    while (true)
    {
        wait(sem);
        if ((prvek = get()) == null)
            break;
        konzumuj();
    }
}

No nevies velkost fronty, lenze fronta je dynamicka datova struktura takze ju mozes zvacsovat pokial ti nedojde pamat nie? Tak si urc nejaku konstantu - velkost ktoru nechces presiahnut a potom to zosynchronizuj pomocou dvoch semaforov a mutexu

semafor semPocet = 0;
semafor semVelkost = N;
semafor mutex = 1;

procudent()
{
	semVelkost.wait();
	mutex.wait();
	fronta.add();
	mutex.signal();
	semPocet.signal();
}

konzument()
{
	semPocet.wait();
	mutex.wait();
	fronta.get();
	mutex.signal();
	semVelkost.signal();
}

Kde semPocet strazi aby konzument pockal ak je fronta prazdna, semVelkost strazi aby producent neprodukoval ak by mal presiahnut tebou stanovenu velkost a mutex na osetrenie KO

díky za rady...

ale já bych potřeboval, když mi skončí producent a fronta bude prázdná, tak bych potřeboval ukončit všechny konzumenty... to mi zatím dělá celkem problém (většinou 1/10 pokusů mi neskončí jedno vlákno)

Nejlíp ti odpověděl zlz a má (zase) pravdu. Další obecná rada ... udělej si logování (stavy semaforů, vláken ...) do nezávislého okna (ala DbgView) nebo pokud to nechceš řešit :), tak zvedni počet na semaforu o víc než o počet konzumentů.

Můžeš to řešit tak, že když producent skončí a přestane produkovat, zvedne hodnotu na semaforu o počet vláken.

Vlákna pak budou mít v kódu to, že pokud queue.pop ( ) == NULL, tak skončí.

Tedy pokud nastane situace, že všechny věci z fronty budou zpracovány, vláknům začne fronta fracet NULLy a tím poznají, že se mají ukončit.

Nebo dáš do producenta nějakou smyčku se sleepem a až bude fronta prázdná, tak ty vlákna odstřelíš. Ale to jen, jestli děláš úkol do školy, kterej ti kontroluje stroj a ne učitel