#include <pthread.h> 
int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr); 
 
int pthread_mutex_lock(pthread_mutex_t *mutex); 
 
int pthread_mutex_unlock(pthread_mutex_t *mutex); 
 
int pthread_mutex_destroy(pthread_mutex_t *mutex); 

、#include <unistd.h> 
#include <pthread.h> 
#include <stdlib.h> 
#include <stdio.h> 
#include <string.h> 
 
 
//聲明線程函數和互斥量 
void* thread_func(void *msg); 
pthread_mutex_t mutex; 
 
 
#define MSG_SIZE 512 
 
 
int main() 
{ 
  int res = -1; 
  pthread_t thread; 
  void *thread_result = NULL; 
  char msg[MSG_SIZE] = {'\0'}; 
  //初始化互斥量，使用默認的互斥量屬性 
  res = pthread_mutex_init(&mutex, NULL); 
  if(res != 0) 
  { 
    perror("pthread_mutex_init failed\n"); 
    exit(EXIT_FAILURE); 
  } 
  //創(chuàng)建子線程，并把msg作為線程函數的參數傳遞給thread_func 
  res = pthread_create(&thread, NULL, thread_func, msg); 
  if(res != 0) 
  { 
    perror("pthread_create failed\n"); 
    exit(EXIT_FAILURE); 
  } 
  //輸入字符串，以串‘end'結束 
  printf("Input some test. Enter 'end' to finish\n"); 
  //把互斥量mutex加鎖，以確保同一時間只有該線程可以訪問msg中的數據 
  pthread_mutex_lock(&mutex); 
  while(strcmp("end\n", msg) != 0) 
  { 
    if(strncmp("TEST", msg, 4) == 0) 
    { 
      strcpy(msg, "copy_data\n"); 
    } 
    else 
    { 
      fgets(msg, MSG_SIZE, stdin); 
    } 
    //把互斥量mutex解鎖，讓其他的線程可以訪問msg中的數據 
    pthread_mutex_unlock(&mutex); 
    sleep(1);//休眠1秒再繼續(xù)循環(huán)，讓其他線程有執(zhí)行的機會 
    pthread_mutex_lock(&mutex); 
  } 
  pthread_mutex_unlock(&mutex); 
  printf("\nWaiting for thread finish...\n"); 
  //等待子線程結束 
  res = pthread_join(thread, &thread_result); 
  if(res != 0) 
  { 
    perror("pthread_join failed\n"); 
    exit(EXIT_FAILURE); 
  } 
  printf("Thread joined\n"); 
  //清理互斥量 
  pthread_mutex_destroy(&mutex); 
  exit(EXIT_SUCCESS); 
} 
void* thread_func(void *msg) 
{ 
  int i = 0; 
  char *ptr = msg; 
  sleep(1); 
  //把互斥量mutex加鎖，以確保同一時間只有該線程可以訪問msg中的數據 
  pthread_mutex_lock(&mutex); 
  while(strcmp("end\n", msg) != 0) 
  { 
    //把小寫字母變成大寫 
    for(i = 0; ptr[i] != '\0'; ++i) 
    { 
      if(ptr[i] >= 'a' && ptr[i] <='z') 
      { 
        ptr[i] -= 'a' - 'A'; 
      } 
    } 
    printf("You input %d characters\n", i-1); 
    printf("To uppercase: %s\n", ptr); 
    //把互斥量mutex解鎖，讓其他的線程可以訪問msg中的數據 
    pthread_mutex_unlock(&mutex); 
    sleep(1);//休眠1秒再繼續(xù)循環(huán)，讓其他線程有執(zhí)行的機會 
    pthread_mutex_lock(&mutex); 
  } 
  pthread_mutex_unlock(&mutex); 
  //退出線程 
  pthread_exit(NULL); 
}