在linux下如可以随意控制一个线程阻塞，运行。

xin8525

如有一个线程：当一个条件变量满足时，它开始运行，在运行中，如果另一个条件变量满足时，它又必须阻塞，
要一个条件变量还是两个，有其它的方法也可以！

其实我最主要是目的就是实现类似守护进程的功能，当没有别的线程运行时，它就运行，一旦别的线程条件满足可以运行时，它必须变为阻塞。

xin8525

我的问题是不是发错了版块啊，怎么没有人回复啊

bleem1998

可以用几个线程锁来帮助线程互相协作阿

lisp

man pthread_cond_wait

langselin

楼主，后来你是怎么做到了，麻烦指点一下小弟！！

syoubin_sai

1. #include <pthread.h>
   
2. #include <stdlib.h>
   
3. #include <stdio.h>
   
4. 
   
5. 
   
6. int send_tag = 0;
   
7. int recv_tag = 0;
   
8. pthread_mutex_t ping_lock;
   
9. pthread_cond_t send_cond;
   
10. pthread_cond_t recv_cond;
    
11. 
    
12. void* th1(void *arg)
    
13. {
    
14.         while (1)
    
15.         {
    
16.                 pthread_mutex_lock(&ping_lock);
    
17.                 recv_tag = 0;
    
18.                 sleep(1);
    
19.                 printf("th1\n");
    
20.                 recv_tag = 1;
    
21.                 pthread_cond_signal(&recv_cond);
    
22.                 while(send_tag == 0){
    
23.                         pthread_cond_wait(&send_cond, &ping_lock);
    
24.                 }
    
25.                 send_tag = 0;
    
26.                 pthread_mutex_unlock(&ping_lock);
    
27. 
    
28.         }
    
29.         return NULL;
    
30. }
    
31. void* th2(void *arg)
    
32. {
    
33.         pthread_t pid = pthread_self();
    
34.         while(1)
    
35.         {
    
36.                 pthread_mutex_lock(&ping_lock);
    
37.                 while(recv_tag == 0){
    
38.                         pthread_cond_wait(&recv_cond, &ping_lock);
    
39.                 }
    
40.                 recv_tag = 0;
    
41.                 printf("th %ld\n", pid);
    
42.                 sleep(1);
    
43.                 send_tag = 1;
    
44.                 pthread_cond_signal(&send_cond);
    
45.                 pthread_mutex_unlock(&ping_lock);
    
46.         }
    
47.         return NULL;
    
48. }
    
49. int main()
    
50. {
    
51.         int i = 0;
    
52.         pthread_t pid;
    
53.         pthread_attr_t attr;
    
54.         (void) pthread_attr_init(&attr);
    
55.         (void) pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
    
56.         (void)pthread_mutex_init(&ping_lock, NULL);
    
57.         (void)pthread_cond_init(&send_cond, NULL);
    
58.         (void)pthread_cond_init(&recv_cond, NULL);
    
59.         pthread_create(&pid, &attr, th1, NULL);
    
60.         for(i = 0; i< 100000; i++){
    
61.                 pthread_create(&pid, &attr, th2, NULL);
    
62.         }
    
63. 
    
64.         while(1);
    
65.         sleep(1);
    
66.         return 0;
    
67. }
    
68. 
    

复制代码