c语言的线程同步
这么高的悬赏，实例放后面。信号量(sem),如同进程一样，线程也可以通过信号量来实现通信，虽然是轻量级的。信号量函数的名字都以"sem_"打头。线程使用的基本信号量函数有四个。
信号量初始化。
intsem_init(sem_t*sem,intpshared,unsignedintvalue);
这是对由sem指定的信号量进行初始化，设置好它的共享选项(linux只支持为0，即表示它是当前进程的局部信号量)，然后给它一个初始值VALUE。
等待信号量。给信号量减1，然后等待直到信号量的值大于0。
intsem_wait(sem_t*sem);
释放信号量。信号量值加1。并通知其他等待线程。
intsem_post(sem_t*sem);
销毁信号量。我们用完信号量后都它进行清理。归还占有的一切资源。
intsem_destroy(sem_t*sem);
#include<stdlib.h>
#include<stdio.h>
#include<unistd.h>
#include<pthread.h>
#include<semaphore.h>
#include<errno.h>
#definereturn_if_fail(p)if((p)==0){printf("[%s]:funcerror!/n",__func__);return;}
typedefstruct_PrivInfo
{
sem_ts1;
sem_ts2;
time_tend_time;
}PrivInfo;
staticvoidinfo_init(PrivInfo*thiz);
staticvoidinfo_destroy(PrivInfo*thiz);
staticvoid*pthread_func_1(PrivInfo*thiz);
staticvoid*pthread_func_2(PrivInfo*thiz);
intmain(intargc,char**argv)
{
pthread_tpt_1=0;
pthread_tpt_2=0;
intret=0;
PrivInfo*thiz=NULL;
thiz=(PrivInfo*)malloc(sizeof(PrivInfo));
if(thiz==NULL)
{
printf("[%s]:Failedtomallocpriv./n");
return-1;
}
info_init(thiz);
ret=pthread_create(&pt_1,NULL,(void*)pthread_func_1,thiz);
if(ret!=0)
{
perror("pthread_1_create:");
}
ret=pthread_create(&pt_2,NULL,(void*)pthread_func_2,thiz);
if(ret!=0)
{
perror("pthread_2_create:");
}
pthread_join(pt_1,NULL);
pthread_join(pt_2,NULL);
info_destroy(thiz);
return0;
}
staticvoidinfo_init(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
thiz->end_time=time(NULL)+10;
sem_init(&thiz->s1,0,1);
sem_init(&thiz->s2,0,0);
return;
}
staticvoidinfo_destroy(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
sem_destroy(&thiz->s1);
sem_destroy(&thiz->s2);
free(thiz);
thiz=NULL;
return;
}
staticvoid*pthread_func_1(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
while(time(NULL)<thiz->end_time)
{
sem_wait(&thiz->s2);
printf("pthread1:pthread1getthelock./n");
sem_post(&thiz->s1);
printf("pthread1:pthread1unlock/n");
sleep(1);
}
return;
}
staticvoid*pthread_func_2(PrivInfo*thiz)
{
return_if_fail(thiz!=NULL);
while(time(NULL)<thiz->end_time)
{
sem_wait(&thiz->s1);
printf("pthread2:pthread2gettheunlock./n");
sem_post(&thiz->s2);
printf("pthread2:pthread2unlock./n");
sleep(1);
}
return;
}
2. 如何用C语言实现多线程下生产者消费者互斥同步问题
整个程序以伪代码形式给出，当做一个提示吧，这样你就应该有思路了
生产者在存储区满时不能再生产，进入等待，消费者同理
完成同步互斥效果
/*----以下为代码部分-----*/
//定义全局变量
int empty = 1;//信号量表示存储单元空，可以生产产品
int full = 0;//信号量表示存储单元空，不可以消费产品
//P操作
void P(int &mutex)
{
*mutex--;
if(*mutex<0)
{
//当前进程挂起的程序实现
}
}
//V操作
void V(int &mutex)
{
*mutex++;
if(*mutex <=0)
{
//唤醒等待中的进程程序实现
}
}
//生产者程序
void procer()
{
P(& empty);//若此时存储区空，则可以生产，否则程序挂起等待
//生产一个产品操作
V(&full);//通知消费者进程，可以取产品
}
//消费者程序
void consumer(){
P(&full);//若此时存储区不空，则可以取产品，否则消费者程序挂起等待
//取走一个产品操作
V(& empty);//通知生产者进程可以生产
}
//主函数
void main()
{
//分别调用生产者，消费者程序，顺序不限，因为已经完成信号量的同步，若发生同步问题就会等待
procer()；
consumer()；
consumer()；
procer()；
………………
}
3. 如何用c语言编写同步与互斥线程 csdn
pthread_create(pthread_t *thread, pthread_attr_t * attr, void *(*start_routine)(void *),void *arg);创建线程（默认为同步线程）
线程的互斥函数有：互斥函数的初始化pthread_mutex_init（），互斥函数的锁定函数pthread_mutex_lock（），互斥函数的预锁定函数pthread_mutex_trylock（），互斥函数的解锁函数pthread_mutex_unlock（），互斥函数的销毁函数pthread_mutex_destroy（）
4. 用C语言开多线程，想让多个相同的子线程同时运行，怎么实现
工作线程是处理后台工作的，创建一个线程非常简单，只需要两步：实线线程函数和开始线程.不需要由CWinThread派生类,你可以不加修改地使用CWinThread。
AfxBeginThread有两种形式，一种是用来创建用户界面线程的，另一种就是用来创建工作线程的.为了开始执行线程，只需要向AfxBeginThread提供下面的参数就可以了.
1.线程函数的地址
2.传送到线程函数的参数
3.（可选的）线程的优先级，可参阅::SetThreadPriority
4.（可选的）线程开始时候的状态,可设置为CREATE_SUSPENEDE
5.（可选的）线程的安全属性,请参阅SECURITY_ATTRIBUTES
实例代码
UINT ThreadProc(LPVOID pParam)
{
return 0;//线程成功完成
}
CWinThread* AfxBeginThreadProc,//线程函数地址
LPVOID pParam,//线程参数
int nPriority=THREAD+PRIORITY_NOMAL,//线程优先级
int nStackSize=0,//线程堆栈大小，默认为1M
DWORD dwCreateFlags=0,
LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL
);
5. C语言中 怎么实现双线程 或者 父子线程啊
运行一个程序，这个运行实体就是一个“进程”。
例如，用鼠标双击IE浏览器的图标，你运行了一个IE“进程”。第一个窗未关，你又用鼠标双击IE浏览器的图标，又出来一个浏览器的窗。这时，你运行了同一个程序的两个进程。
对于自己写的程序也如此。运行它，这个运行实体就是一个“进程”。同时运行两个，就是两个进程。计算机分别对两个进程分配资源，直到进程结束，收回资源。
线程是进程里真真跑的线路，真真执行的运算，每个进程有一个主线程。进程里可以开第二第三条新的执行线路，gcc 用 pthread_create()，VC++ 用 CreateThread(), 这就叫双线程和多线程。进程是线程的容器，同一进程的线程共享它们进程的资源。线程里建的线程就是父子线程。
两个或多个进程协同工作时，需要互相交换信息，有些情况下进程间交换的少量信息，有些情况下进程间交换大批信息。这就要通讯。通讯方式不止一种。管道就是一种。VC++ 用 CreatePipe() 函数建立。
管道的实质是一个共享文件，可借助于文件系统的机制实现，创建、打开、关闭和读写.
一个进程正在使用某个管道写入或读出数据时，另一个进程就必须等待. 发送者和接收者双方必须知道对方是否存在，如果对方已经不存在，就没有必要再发送信息.,发送信息和接收信息之间要协调，当写进程把一定数量的数据写入管道，就去睡眠等待，直到读进程取走数据后，把它唤醒。
VC++ 线程例子：
#include <windows.h>
#include <iostream.h>
DWORD WINAPI fun1(LPVOID lp);
DWORD WINAPI fun2(LPVOID lp);
int piao=500;
int main()
{
HANDLE pthread1,pthread2;
pthread1=CreateThread(0,0,fun1,0,0,0);
pthread2=CreateThread(0,0,fun2,0,0,0);
CloseHandle(pthread1);
CloseHandle(pthread2);
Sleep(3000);
return 0;
}
DWORD WINAPI fun1(LPVOID lp)
{
while(1)
{
if(piao>0)
cout<< "thread-1-"<< piao--<<endl;
else
break;
}
return 0;
}
DWORD WINAPI fun2(LPVOID lp)
{
while(1)
{
if(piao>0)
cout<<"thread-2-"<<piao--<<endl;
else
break;
}
return 0;
}
===================================
建管道函数原形：
BOOL CreatePipe(
PHANDLE hReadPipe, // read handle
PHANDLE hWritePipe, // write handle
LPSECURITY_ATTRIBUTES lpPipeAttributes, // security attributes
DWORD nSize // pipe size
);
6. C语言如何实现多线程同时运行
1、点击菜单栏的“Project”选项卡，下拉列表的最后一项“Project options...”是对当前工程的的属性进行设置的。
7. C语言如何在线程间实现同步和互斥
线程之间的同步和互斥解决的问题是线程对共同资源进行访问。Posix有两种方式：
信号量和互斥锁；信号量适用同时可用的资源为多个的情况；互斥锁适用于线程可用的资源只有一个的情况
1、互斥锁：互斥锁是用加锁的方式来控制对公共资源的原子操作(一旦开始进行就不会被打断的操作)
互斥锁只有上锁和解锁两种状态。互斥锁可以看作是特殊意义的全局变量，因为在同一时刻只有一个线程能够对互斥锁进行操作；只有上锁的进程才可以对公共资源进行访问，其他进程只能等到该进程解锁才可以对公共资源进行操作。
互斥锁操作函数：
pthread_mutex_init();//初始化
pthread_mutex_lock();//上锁 参数：pthread_mutex_t *mutex
pthread_mutex_trylock();//判断上锁 参数：pthread_mutex_t *mutex
pthread_mutex_unlock();//解锁 参数：pthread_mutex_t *mutex
pthread_mutex_release();//消除互斥锁 参数：pthread_mutex_t *mutex
互斥锁分为快速互斥锁、递归互斥锁、检错互斥锁；在 init 的时候确定
int pthread_mutex_t(pthread_mutex_t *mutex, const pthread_mutex_t mutexattr);
第一个参数：进行操作的锁
mutexattr：锁的类型，默认快速互斥锁（阻塞）123456789
2、信号量：信号量本质上是一个计数器，在操作系统做用于PV原子操作；
P操作使计数器－1；V操作使计数器+1.
在互斥操作中可以是使用一个信号量；在同步操作中需要使用多个信号量，并设置不同的初始值安排它们顺序执行
sem_init(); // 初始化操作
sem_wait(); // P操作，计数器减一；阻塞 参数：sem_t *sem
sem_trywait(); // P操作，计数器减一；非阻塞 参数：sem_t *sem
sem_post(); // V操作，计数器加一 参数：sem_t *sem
sem_destroy(); // 销毁信号量 参数：sem_t *sem
sem_init(sem_t *sem, int pshared, int value);
pshared用于指定多少个进程共享；value初始值
8. 用C语言如何实现多线程同时运行的情况下，各个线程输出不同的随机数
1、使用pthread库执行多线程，这个是Linux下的线程库 Windows下应该有自己的API，不过这种东西一般还是以Linux为标准。pthread_create()创建一个线程，传入fun()的函数指针就行了。然后这个Beep()的需求要进行线程间通信，可以用共享内存的方法，设一个bool变量flag共享，然后beep的时候设为false，beep完设成true。fun()里面每次看一下这个flag，是false的话就不做动作等下一秒，基本可以满足需求。
2、例程：
#include<pthread.h>
#include<stdio.h>
#include<sys/time.h>
#include<string.h>
#defineMAX10
pthread_tthread[2];
pthread_mutex_tmut;
intnumber=0,i;
void*thread1()
{
printf("thread1:I'mthread1 ");
for(i=0;i<MAX;i++)
{
printf("thread1:number=%d ",number);
pthread_mutex_lock(&mut);
number++;
pthread_mutex_unlock(&mut);
sleep(2);
}
printf("thread1:主函数在等我完成任务吗？ ");
pthread_exit(NULL);
}
void*thread2()
{
printf("thread2:I'mthread2 ");
for(i=0;i<MAX;i++)
{
printf("thread2:number=%d ",number);
pthread_mutex_lock(&mut);
number++;
pthread_mutex_unlock(&mut);
sleep(3);
}
printf("thread2:主函数在等我完成任务吗？ ");
pthread_exit(NULL);
}
voidthread_create(void)
{
inttemp;
memset(&thread,0,sizeof(thread));//comment1
/*创建线程*/
if((temp=pthread_create(&thread[0],NULL,thread1,NULL))!=0)//comment2
printf("线程1创建失败! ");
else
printf("线程1被创建 ");
if((temp=pthread_create(&thread[1],NULL,thread2,NULL))!=0)//comment3
printf("线程2创建失败");
else
printf("线程2被创建 ");
}
voidthread_wait(void)
{
/*等待线程结束*/
if(thread[0]!=0){//comment4
pthread_join(thread[0],NULL);
printf("线程1已经结束 ");
}
if(thread[1]!=0){//comment5
pthread_join(thread[1],NULL);
printf("线程2已经结束 ");
}
}
intmain()
{
/*用默认属性初始化互斥锁*/
pthread_mutex_init(&mut,NULL);
printf("我是主函数哦，我正在创建线程，呵呵 ");
thread_create();
printf("我是主函数哦，我正在等待线程完成任务阿，呵呵 ");
thread_wait();
return0;
}
9. c语言多个线程循环次数极大时如何减小时间差实现同步运行
使用线程同步技术，可以协调多线程的同步问题
10. C语言多线程线程同步可以干什么
线程同步
比如你要操作大量数据，再有界面的情况下会卡住，实际上是在运行的，但是你会以为它卡死了，线程同步就是解决这类问题，让操作量大的工作交给一个线程，界面的显示交给另一个线程