代码:

---

//gcc -D_REENTRANT -I/usr/include/nptl -L/usr/lib/nptl -lpthread filename.c -o filename 
#include <stdio.h> 
//     #include <string.h> 
// #include <sys/types.h> 
#include <unistd.h> 
#include <stdlib.h 
#include <pthread.h> 
#include <semaphore.h> 
void *thread_function(void *arg); 
sem_t bin_sem;                              //定义信号灯，作用和PV原语类似 
#define WORK_SIZE 1024 
char work_are[WORK_SIZE]; 
int main(){ 
    int res;  pthread_t a_thread;                                  //定义线程标识符，后面要用   
    void *thread_result;     
    res=sem_init(&bin_sem,0,0);                        //初始化信号灯
    if(res!= 0){     
        perror("Semaphore initialization failed");     
        exit(EXIT_FAILURE);   
    }   
    res=pthread_create(&a_thread,NULL,thread_function,NULL);           //创建线程   
    if(res!=0){   
        perror("Thread creation failed");     
        exit(EXIT_FAILURE); 
    }   
    printf("Input some text. Enter 'end' to finish\n"); 
    while(strncmp("end",work_are,3)!=0){     
        fgets(work_are,WORK_SIZE,stdin);     
        sem_post(&bin_sem);                  //当用户输入一行后，让信号灯加1以激活thread_function()   
    }     
    printf("\n Waiting for thread to finish... \n");   
    res=pthread_join(a_thread,&thread_result);        //等待a_thread指定的线程结束.   
    if(res!=0){   
        perror("Thread join failed");     
        exit(EXIT_FAILURE); 
    }   
    printf("Thread joined\n");     
    // 
    sem_destroy(&bin_sem);                                    //销毁信号灯 
    exit(EXIT_SUCCESS); 
} 
//下面是线程函数，posix标准要求是void *fun(void*)类型
void *thread_function(void *arg){   
    //check if start or not   
    sem_wait(&bin_sem);                    //等待，如果信号灯大于0，就减1然后继续执行   
    //work for character count until type 'end' 
    while(strncmp("end",work_are,3)!=0){     
        //processing     
        printf("you input %d characters\n",strlen(work_are) -1);     
        //stop processing     
        sem_wait(&bin_sem);   
    }     
    pthread_exit(null); 
}

---

代码:

---

#include <unistd.h>
#include <pthread.h>

void *thread_fun(void *);

int main(void) {
        pthread_t pt;
        int res;

        res=pthread_create(&pt,NULL,thread_fun,NULL);

        if(res!=0) {
                perror("pthread_create");
                exit(1);
        }

        for(;;) {
                sleep(1);
                printf("this is main.\n");
        }
}

void *thread_fun(void *arg) {
        for(;;) {
                sleep(1);
                printf("this is pthread_fun.\n");
        }
}

---