互斥鎖

互斥鎖也是屬于線程之間處理同步互斥方式，有上鎖/解鎖兩種狀態。

互斥鎖函數接口
1）初始化互斥鎖
pthread_mutex_init()
man 3 pthread_mutex_init
(找不到的情況下首先
sudo apt-get install glibc-doc
sudo apt-get install manpages-posix-dev)

動態初始化
int pthread_mutex_init(pthread_mutex_t *mutex,
const pthread_mutexattr_t *attr);

mutex： pthread_mutex_t 互斥鎖的數據類型
attr： 鎖的屬性，普通屬性默認是阻塞鎖 NULL

失敗返回錯誤碼

靜態初始化 默認屬性 NULL
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

如果屬性是普通屬性，則靜態初始化與動態初始化一致。
初始化完結果： 鎖被創建并且已經處于解鎖的狀態。

2）上鎖 pthread_mutex_lock
man 3 pthread_mutex_lock

mutex： 必須已經初始化過的互斥鎖的地址,并且鎖解鎖狀態才能返回！
失敗f返回錯誤碼

3）解鎖 pthread_mutex_unlock
man 3 pthread_mutex_unlock

mutex： 必須已經初始化過的互斥鎖的地址，并且鎖上鎖狀態才能返回！
失敗返回錯誤碼

4）銷毀互斥鎖 pthread_mutex_destroy()

man 3 pthread_mutex_destroy
mutex： 必須已經初始化過的互斥鎖的地址
失敗返回錯誤碼

pthread_mutex_t m = PTHREAD_MUTEX_INITIALIZER; //靜態初始化

void *Jack_fun(void *arg)
{
	char *p = (char *)arg;
	while(1)
	{
		//發消息的Jack，必須先上鎖
		pthread_mutex_lock(&m);
		
		fgets(p,1024,stdin);
		
		//解鎖
		pthread_mutex_unlock(&m);
		
		if(strncmp(p,"quit",4) == 0)
		{
			break;
		}
		
		usleep(100000);
	}
	
	pthread_exit(NULL);
	
}

void *Rose_fun(void *arg)
{
	usleep(100000);
	char *p = (char *)arg;
	while(1)
	{
		//接收消息的Rose，后上鎖
		pthread_mutex_lock(&m);
		
		printf("from Jack = %s",p);
		
		//解鎖
		pthread_mutex_unlock(&m);
		
		if(strncmp(p,"quit",4) == 0)
		{
			break;
		}
		
		usleep(200000);
	}
	
	pthread_exit(NULL);
}

int main()
{
	//1. 申請key值
	key_t key = ftok(".",10);
	
	//2. ID 
	int shmid = shmget(key,1024,IPC_CREAT|0666);
	
	//3. 映射
	char *p = shmat(shmid,NULL,0);
	
	//4. 兩個子線程
	pthread_t Jack_tid,Rose_tid;
	pthread_create(&Jack_tid,NULL,Jack_fun,(void *)p);
	pthread_create(&Rose_tid,NULL,Rose_fun,(void *)p);
	
	//5. 接合線程
	pthread_join(Jack_tid,NULL);
	pthread_join(Rose_tid,NULL);
	
	//6. 撤銷內存
	shmdt(p);
	shmctl(shmid,IPC_RMID,NULL);
	
	//7. 鎖
	pthread_mutex_destroy(&m);
	
	return 0;
}