Thread Synchronization C++

Question

У меня такая странная проблема с потоками. На моем Mac с OS X это прекрасно работает, но как только я больше расскажу о своем рабочем столе, на котором работает Ubuntu, я столкнулся с проблемами.

По сути то, что я делаю следующее:

Function() { 

    for(i = 1 to 10) 
     while(array not completely changed) { 
     pthread_mutex_lock(&lock); 
     -- perform actions 
     pthread_mutex_unlock(&unlock); 
     } 
    } 
} 

И у меня есть две темы, работающие эту функцию. Несмотря на то, что, как предполагается, работает таким образом, что:

Thread 1 grabs lock 
performs opperations on array 
Thread 1 releases lock 
Thread 2 grabs lock 
performs calculations on array 
Thread 2 releases lock 

и так далее в спину и вперед образец до тех пор, пока массив не были завершены изменены, но в Linux все из расчета резьбы 1 завершена, а затем Начинается тема 2.

Так что я получаю:

Thread 1 grabs lock 
performs opperations on array 
Thread 1 releases lock 
Thread 1 grabs lock 
performs calculations on array 
Thread 1 releases lock 
Thread 1 grabs lock 
performs calculations on array 
Thread 1 releases lock 

И так далее, пока массив не будет полностью изменен, как только я приращение для цикла, то поток 2 будет выполнять все расчеты и продолжить эту картину.

Может ли кто-нибудь объяснить, что происходит?

Answer 1

Вы испытываете «голод». Добавьте небольшой вызов nanosleep, чтобы дать другим потокам возможность запускать. Добавьте вызов вне пары мьютексов (например, после разблокировки). Тема 1 - монополизация вещей.

Вы можете также рассмотреть вопрос о реструктуризации и расщеплению до критической [требует блокировки] против некритического работы:

while (more) { 
    lock ... 
     do critical stuff ... 
    unlock ... 
    nanosleep ... 
    do non-critical stuff 
}