Administrace komentářů

Dekuji za reakci, je to pro me inspirujici.

Jenom bych se chtel zeptat, zda neni potreba osetrit mutextem pristup do pole worker_data wdata_buffer[n_workers]; i presto ze kazdy worker si bude zapisovat akorat do toho sveho indexu.

V tom mem ukazkovem prikladu jsem to pro jednoduchost napsal tak, ze kazdy worker vykonava stejny kod . Ve skutecnosti to bude tak, ze kazdy worker bude provadet uplne neco jineho.

Pokud jsem dobre pochopil Vasi ukazku, tak ze zacatku rozdate workerum data:

    for (i=0; i<n_workers; i++) {
      prepare_data(&wdata_buffer[i]);
      pthread_mutex_lock(&mtx_aw);
      active_workers++;
      pthread_mutex_unlock(&mtx_aw);
      notify_worker(&wdata_buffer[i]);  /* wait_for_data() waits for this */
    }

 A pak se ceka, az vsichni workeri odeslou vysledek:

   pthread_mutex_lock(&mtx_aw);
    while (active_workers > 0)
      pthread_cond_wait(&cv_aw, &mtx_aw);
    pthread_mutex_unlock(&mtx_aw);

Coz pro me neni moc vhodne, protoze jak jsem jiz uvedl, kazdy worker bude delat jiny kod a kazdemu to bude trvat jinou dobu, nez budou pripraveni odesilat data.

Dalsi veci co neni potreba je to opetovne odesilani pracovnich dat pro workery. Worker po vytvoreni bude vedet co ma delat po celou dobu jeho zivota. Kdybych dal jednoduchy priklad, jeden z workeru se vytvori s attributem www.abclinuxu.cz  a on bude mit na starost napriklad kazdou minutu pingnout www.abclinuxu.cz a treba v pripade pingu vetsiho jak 500ms notifikuje bose a preda mu tuto zpravu.

Boss vytvori na zacatku sve workery a pak jenom bude cekat az mu nektery z nich neco posle.Takze ja hledam techniku jak uspat bosse a jak ho z nejakeho workera probudit, a predat mu nejake data. Na ty data boss zareaguje a pak se znovu uspi.

Napadlo me napriklad udelat strukturu message_for_boss { int WorkerID; const char *Message } a worker by toto naplnil a kdyz se boss vzbudi, precetl by si WorkerID a vedel by tak od koho zprava je.

Mohlo by to tak byt?

Dekuji Tomas