1、添加线程相关的头文件：#include<pthread.h>
2、线程创建函数是pthread_create()函数，该函数的原型为：
int pthread_create(pthread_t *thread,pthread_attr_t *attr,void* (*start_routine)(void*),void *arg)3、线程退出函数是pthread_exit()函数，该函数的原型为：
void pthread_exit(void *retval)创建线程的示例程序如下：
/***程序说明：创建线程函数pthread_create()函数的使用。
*/
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
//打印标识符的函数
void print_ids(const char *str)
{
pid_t pid //进程标识符
pthread_t tid //线程标识符
pid=getpid() //获得进程号
tid=pthread_self() //获得线程号
printf("%s pid:%u tid:%u (0x%x)\n",
str,(unsigned int)pid,(unsigned int)tid,(unsigned int)tid) //打印进程号和线程号
}
//线程函数
void* pthread_func(void *arg)
{
print_ids("new thread:") //打印新建线程号
return ((void*)0)
}
//主函数
int main()
{
int err
pthread_t ntid //线程号
err=pthread_create(&ntid,NULL,pthread_func,NULL) //创建一个线程
if(err != 0)
{
printf("create thread failed:%s\n",strerror(err))
exit(-1)
}
print_ids("main thread:") //打印主线程号
sleep(2)
return 0
}
面只有两个线程，是生产者/消费者模式，已编译通过，注释很详细。
/* 以生产者和消费者模型问题来阐述Linux线程的控制和通信你
生产者线程将生产的产品送入缓冲区，消费者线程则从中取出产品。
缓冲区有N个，是一个环形的缓冲池。
*/
#include <stdio.h>
#include <pthread.h>
#define BUFFER_SIZE 16
struct prodcons
{
int buffer[BUFFER_SIZE]/*实际存放数据的数组*/
pthread_mutex_t lock/*互斥体lock，用于对缓冲区的互斥操作*/
int readpos,writepos/*读写指针*/
pthread_cond_t notempty/*缓冲区非空的条件变量*/
pthread_cond_t notfull/*缓冲区未满 的条件变量*/
}
/*初始化缓冲区*/
void pthread_init( struct prodcons *p)
{
pthread_mutex_init(&p->lock,NULL)
pthread_cond_init(&p->notempty,NULL)
pthread_cond_init(&p->notfull,NULL)
p->readpos = 0
p->writepos = 0
}
/*将产品放入缓冲区，这里是存入一个整数*/
void put(struct prodcons *p,int data)
{
pthread_mutex_lock(&p->lock)
/*等待缓冲区未满*/
if((p->writepos +1)%BUFFER_SIZE ==p->readpos)
{
pthread_cond_wait(&p->notfull,&p->lock)
}
p->buffer[p->writepos] =data
p->writepos++
if(p->writepos >= BUFFER_SIZE)
p->writepos = 0
pthread_cond_signal(&p->notempty)
pthread_mutex_unlock(&p->lock)
}
/*从缓冲区取出整数*/
int get(struct prodcons *p)
{
int data
pthread_mutex_lock(&p->lock)
/*等待缓冲区非空*/
if(p->writepos == p->readpos)
{
pthread_cond_wait(&p->notempty ,&p->lock)//非空就设置条件变量notempty
}
/*读书据，移动读指针*/
data = p->buffer[p->readpos]
p->readpos++
if(p->readpos == BUFFER_SIZE)
p->readpos = 0
/*设置缓冲区未满的条件变量*/
pthread_cond_signal(&p->notfull)
pthread_mutex_unlock(&p->lock)
return data
}
/*测试：生产站线程将1 到1000的整数送入缓冲区，消费者线程从缓冲区中获取整数，两者都打印信息*/
#define OVER (-1)
struct prodcons buffer
void *producer(void *data)
{
int n
for( n=0n<1000n++)
{
printf("%d ------>\n",n)
put(&buffer,n)
}
put(&buffer,OVER)
return NULL
}
void *consumer(void *data)
{
int d
while(1)
{
d = get(&buffer)
if(d == OVER)
break
else
printf("----->%d\n",d)
}
return NULL
}
int main()
{
pthread_t th_p,th_c
void *retval
pthread_init(&buffer)
pthread_create(&th_p,NULL,producer,0)
pthread_create(&th_c,NULL,consumer,0)
/*等待两个线程结束*/
pthread_join(th_p, &retval)
pthread_join(th_c,&retval)
return 0
}
