- 论坛徽章:
- 0
|
/* condmutex.c
*
*/
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <errno.h>
int gnum = 0; // globle variable
pthread_mutex_t mutex;
pthread_cond_t cond;
void pthread_func_1 (void);
void pthread_func_2 (void);
int main (void)
{
pthread_t tid1 = 0;
pthread_t tid2 = 0;
int ret = 0;
pthread_mutex_init (&mutex, NULL);
pthread_cond_init(&cond,NULL);
ret = pthread_create (&tid1, NULL, (void *)pthread_func_1, NULL);
if (ret != 0) {
perror ("pthread_1_create" ;
}
ret = pthread_create (&tid2, NULL, (void *)pthread_func_2, NULL);
if (ret != 0) {
perror ("pthread_2_create";
}
sleep(1);
pthread_join (tid1, NULL);
pthread_join (tid2, NULL);
printf ("main programme exit!/n";
return 0;
}
void pthread_func_1 (void)
{
int i = 0;
for (i; i<10; i++)
{
printf ("This is pthread1!/n";
pthread_mutex_lock(&mutex); // acquire mutex lock
while (gnum <= 3) {
pthread_cond_wait(&cond, &mutex);
}
gnum = 0; // gnum++; // critical resource.
printf ("Thread1 add one to num:%d/n", gnum);
pthread_mutex_unlock(&mutex); // release mutex lock
sleep (1);
}
pthread_exit(0);
}
void pthread_func_2 (void)
{
int i = 0;
for (i; i<15; i++)
{
printf ("This is pthread2!/n";
pthread_mutex_lock(&mutex); // acquire nutex lock.
gnum++;
printf ("Thread2 add one to num:%d/n", gnum);
if(gnum == 4) {
pthread_cond_signal(&cond);
}
pthread_mutex_unlock(&mutex);
sleep(1);
}
pthread_exit (0);
}
程序运行起来就没得结果的！也不知道多线程的该怎么调试....谢谢解答 |
|
免费注册
发表于 2011-11-13 11:03
