函数:
线程:
int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg);
int pthread_join(pthread_t thread, void **retval);
void pthread_exit(void *retval);
参数:
thread 新建线程的id;attr 新建线程的属性
start_routine 线程的入口函数;arg入口函数的参数; retval保存线程返回值
头文件:<pthread.h>
编译必须包含pthread库:gcc -pthread pthread.c -o pthread
返回值:成功:0
失败:错误码
互斥锁:
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);
参数:
mutex 互斥锁指针; mutexattr属性
头文件:<pthread.h>
返回值:成功:0
失败:错误码
上代码:
#include <stdio.h>
#include <pthread.h>
pthread_t thread[2];
int number = 0;
pthread_mutex_t mut;
void worker1()
{
printf("I'm worker1\n");
for (int i = 0; i < 10; i++)
{
pthread_mutex_lock(&mut);
number++;
pthread_mutex_unlock(&mut);
printf("worker number is%d\n", number);
sleep(1);
}
pthread_exit(NULL);
}
void worker2()
{
printf("I'm worker2\n");
for (int i = 0; i < 10; i++)
{
pthread_mutex_lock(&mut);
number++;
pthread_mutex_unlock(&mut);
printf("worker number is%d\n", number);
sleep(1);
}
pthread_exit(NULL);
}
int main()
{
pthread_mutex_init(&mut, NULL);
//1、创建工人1线程
pthread_create(&thread[0], NULL, worker1, NULL);
//2、创建工人2线程
pthread_create(&thread[1], NULL, worker2, NULL);
//3、等待工人1线程
pthread_join(thread[0], NULL);
//4、等待工人2线程
pthread_join(thread[1], NULL);
return 0;
}