1

我想通过使用互斥锁访问数组的每个元素来使结构数组中的每个元素都成为线程安全的。

这是我的结构：

typedef struct {
  void      *value;
  void      *key;
  uint32_t  value_length;
  uint32_t  key_length;
  uint64_t  access_count;
  void      *next;
  pthread_mutex_t *mutex;
} lruc_item;

我有一个这种结构的数组，并且想使用互斥锁以使结构元素线程安全。

我尝试在函数中的一个数组元素上使用锁，然后故意没有解锁它，只是为了确保我的锁工作正常，但奇怪的是没有死锁并且第二个函数访问相同数组元素能够访问它。

有人可以指导我如何使用互斥锁锁定结构数组中的每个元素（以使结构线程的每个元素安全）。

示例代码来解释我的观点：

/** FUNCTION THAT CREATES ELEMENTS OF THE STRUCTURE **/

lruc_item *create_item(lruc *cache) {
  lruc_item *item = NULL;

item = (lruc_item *) calloc(sizeof(lruc_item), 1);

item->mutex = (pthread_mutex_t *) malloc(sizeof(pthread_mutex_t));
  if(pthread_mutex_init(item->mutex, NULL)) {
    perror("LRU Cache unable to initialise mutex for page");
    return NULL;
     }

  }

 return item;
}


set()
{
item = create_item(cache);

  pthread_mutex_lock(item->mutex);
    item->value = value;
    item->key = key;
    item->value_length = value_length;
    item->key_length = key_length;
    item->access_count = ++cache->access_count;

  pthread_mutex_unlock(item->mutex);     /** (LINE P) tried commenting out this to check  proper working of mutex(deadlock expected if the same "item" is accessed in another function)  **/


}

get(lruc_item *item)
{

  pthread_mutex_lock(item->mutex);   /** deadlock doesn't occur when "LINE P" is commented out**/ 
    *value = item->value;
    item->access_count = ++cache->access_count;
  pthread_mutex_unlock(item->mutex);

}
4

1 回答 1

0

需要注意的是，互斥锁只锁定来自其他线程的代码。 如果您尝试WaitForMultipleObjects在同一个线程中使用相同的互斥锁执行它不会阻塞。我假设是 Windows，因为你没有详细说明。

但是，如果您提供更多细节，也许我们可以查明问题的真正所在。

现在，再次假设 Windows，如果您想对单个元素进行“线程安全”的访问，您可能需要考虑InterlockedExchange-class 函数而不是互斥体。例如：

InterlockExchange(&s.value_length, newValue);

或者

InterlockedExchange64(&s.access_count, new64Value);

或者

InterlockedExchangePointer(&s.value, newPointer);

如果您要做的是确保对结构的多个元素访问（作为事务）是线程安全的，那么互斥锁可以为您做到这一点。Mutex 在跨进程边界时很有用。如果您只处理单个进程，那么关键部分可能是一个更好的主意。

于 2012-08-10T18:55:19.320 回答