Приобретите замок на двух взаимных ошибках и избегайте взаимоблокировки

Question

Следующий код содержит потенциальный тупик, но представляется необходимым: чтобы безопасно копировать данные в один контейнер из другого, оба контейнера должны быть заблокированы, чтобы предотвратить появление изменений в другом потоке.

void foo::copy(const foo & rhs) 
{ 
    pMutex->lock(); 
    rhs.pMutex->lock(); 
    // do copy 
} 

У Foo есть контейнер STL и «сделать копию» по существу состоит из использования std :: copy. Как заблокировать оба мьютекса без введения тупика?

Answer 1

Наденьте какой-то общий заказ на экземпляры foo и всегда приобретайте их замки в порядке возрастания или убывания, , например., foo1->lock(), а затем foo2->lock().

Другой подход - использовать функциональную семантику и вместо этого написать метод foo::clone, который создает новый экземпляр, а не сбивает существующий.

Если ваш код выполняет много блокировки, вам может потребоваться комплексный алгоритм устранения взаимоблокировки, такой как banker's algorithm.

Answer 2

Как насчет этого?

void foo::copy(const foo & rhs) 
{ 
    scopedLock lock(rhs.pMutex); // release mutex in destructor 
    foo tmp(rhs); 
    swap(tmp); // no throw swap locked internally 
} 

Это безопасное исключение, а также хорошая потоковая безопасность. Чтобы быть 100% -ной нитью, вам нужно будет просмотреть весь путь кода и повторить повторный просмотр с другим набором глаз, после этого снова просмотрите его ...

Answer 3

Чтобы избежать тупика, вероятно, это лучше всего, подождать до как ресурсы могут быть заблокированы:

Dont знаю, какой мьютекс API вы используете так вот некоторый произвольный код псевдо, предположим, что can_lock() только проверяет, если он может заблокировать мьютекс, и что try_lock() возвращает истину, если он сделал замок, и ложь , если мьютекс уже заблокирован кем-то другим.

void foo::copy(const foo & rhs) 
{ 
    for(;;) 
    { 
     if(! pMutex->cany_lock() || ! rhs.pMutex->cany_lock()) 
     { 
      // Depending on your environment call or dont call sleep() 
      continue; 
     } 
     if(! pMutex->try_lock()) 
      continue; 
     if(! rhs.pMutex->try_lock()) 
     { 
      pMutex->try_lock() 
      continue; 
     } 
     break; 
    } 
    // do copy 
} 

Answer 4

Вы можете попробовать блокировки оба мьютексы в то же самое время, используя scoped_lock или auto_lock .... как банковский перевод сделать ...

void Transfer(Receiver recv, Sender send) 
{ 
    scoped_lock rlock(recv.mutex); 
    scoper_lock slock(send.mutex); 

    //do transaction. 
}