怎么基于linuxthreads2.0.1線程源碼分析specific.c

這篇文章將為大家詳細(xì)講解有關(guān)怎么基于linuxthreads2.0.1線程源碼分析specific.c，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

該文件是線程私有數(shù)據(jù)的實(shí)現(xiàn)。在線程tcb里有一個(gè)數(shù)組，保存了一系列的鍵對(duì)值。從而實(shí)現(xiàn)了線程的私有數(shù)據(jù)存儲(chǔ)。線程想擁有自己的數(shù)據(jù)時(shí)，首先獲取一個(gè)鍵，然后在tcb中保存一個(gè)鍵對(duì)值即可。

   
     
 
    
    
/

/* Thread-specific data */

#include <errno.h>
#include <stddef.h>
#include "pthread.h"
#include "internals.h"

typedef void (*destr_function)(void *);

/* Table of keys. */

struct pthread_key_struct {
  int in_use;                   /* already allocated? */
  destr_function destr;         /* destruction routine */
};

static struct pthread_key_struct pthread_keys[PTHREAD_KEYS_MAX] =
  { { 0, NULL } };

/* Mutex to protect access to pthread_keys */

static pthread_mutex_t pthread_keys_mutex = PTHREAD_MUTEX_INITIALIZER;

/* Create a new key */
// 創(chuàng)建一個(gè)key
int __pthread_key_create(pthread_key_t * key, destr_function destr)
{
  int i;
  // 加鎖
  pthread_mutex_lock(&pthread_keys_mutex);
  // 從列表中找一項(xiàng)空閑的
  for (i = 0; i < PTHREAD_KEYS_MAX; i++) {
    if (! pthread_keys[i].in_use) {
      pthread_keys[i].in_use = 1;
      pthread_keys[i].destr = destr;
      // 找到則解鎖并返回鍵值
      pthread_mutex_unlock(&pthread_keys_mutex);
      *key = i;
      return 0;
    }
  }
  // 找不到則解鎖
  pthread_mutex_unlock(&pthread_keys_mutex);
  return EAGAIN;
}
weak_alias (__pthread_key_create, pthread_key_create)

/* Delete a key */
// 刪除一個(gè)鍵對(duì)應(yīng)的項(xiàng)
int pthread_key_delete(pthread_key_t key)
{
  pthread_mutex_lock(&pthread_keys_mutex);
  if (key >= PTHREAD_KEYS_MAX || !pthread_keys[key].in_use) {
    pthread_mutex_unlock(&pthread_keys_mutex);
    return EINVAL;
  }
  pthread_keys[key].in_use = 0;
  pthread_keys[key].destr = NULL;
  pthread_mutex_unlock(&pthread_keys_mutex);
  return 0;
}

/* Set the value of a key */
// 關(guān)聯(lián)鍵對(duì)應(yīng)的值
int __pthread_setspecific(pthread_key_t key, const void * pointer)
{
  pthread_t self = thread_self();
  if (key >= PTHREAD_KEYS_MAX) return EINVAL;
  self->p_specific[key] = (void *) pointer;
  return 0;
}
weak_alias (__pthread_setspecific, pthread_setspecific)

/* Get the value of a key */

void * __pthread_getspecific(pthread_key_t key)
{
  pthread_t self = thread_self();
  if (key >= PTHREAD_KEYS_MAX)
    return NULL;
  else
    return self->p_specific[key];
}
weak_alias (__pthread_getspecific, pthread_getspecific)

/* Call the destruction routines on all keys */
// 逐個(gè)調(diào)用pthread_keys數(shù)組中的destr函數(shù)，并以線程關(guān)聯(lián)的value為參數(shù)
void __pthread_destroy_specifics()
{
  int i;
  pthread_t self = thread_self();
  destr_function destr;
  void * data;

  for (i = 0; i < PTHREAD_KEYS_MAX; i++) {
    // 銷毀時(shí)執(zhí)行的函數(shù)
    destr = pthread_keys[i].destr;
    // 獲取鍵對(duì)應(yīng)的值
    data = self->p_specific[i];
    // 執(zhí)行
    if (destr != NULL && data != NULL) destr(data);
  }
}
    

關(guān)于怎么基于linuxthreads2.0.1線程源碼分析specific.c就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。