1.pipe

用與實現同一個進程下不同線程間的通信(跟IPC進程間通信中的具有血緣關系的進程通信實現方式一樣)

#include

#include

#include

#include

#include

using namespace std;

void *func(void * fd)

{

char str[] = "this is write thread!\n";

write( *(int*)fd, str, strlen(str) );

}

int main()

{

int fd[2];

char readbuf[1024];

if(pipe(fd) < 0)

{

printf("pipe error!\n");

}

pthread_t tid = 0;

pthread_create(&tid, NULL, func, &fd[1]);

pthread_join(tid, NULL);

sleep(3);

// read buf from child thread

read( fd[0], readbuf, sizeof(readbuf) );

printf("read buf = %s\n", readbuf);

return 0;

}

2.fifo

用於實現不同進程的線程間通信。不同進程的線程間的通信等同於不同進程間的通信。

讀線程

#include

#include

#include

#include

#include

#include

#include

#include

void *func(void *fd)

{

char readbuf[1024];

read( *(int*)fd, readbuf, 30);

printf("this is Thread_read!\n");

printf("Receive message: %s\n", readbuf);

close(*(int*)fd);

}

int main()

{

int fd;

char buff[2048];

if(mkfifo("fifo", 0666) < 0 && errno != EEXIST)

{

printf("create FIFO falied!\n");

return 0;

}

fd = open("fifo", O_RDONLY);

if(fd < 0)

{

printf("open FIFO falied!\n");

}

pthread_t tid = 0;

pthread_create(&tid, NULL, func, &fd);

pthread_join(tid, NULL);

//sleep(3);

return 0;

}

//g++ -o Thread_read Thread_read.cpp -lpthread

寫線程

#include

#include

#include

#include

#include

void *func(void * fd)

{

int wri = write(*(int*)fd, "this is Thread_write", 30);

if(wri < 0)

{

printf("wirte fifo failed!\n");

}

close(*(int*)fd);

}

int main()

{

int fd = open("fifo", O_WRONLY);

if(fd < 0)

{

printf("open fifo failed!\n");

return 0;

}

pthread_t tid = 1;

pthread_create(&tid, NULL, func, &fd);

pthread_join(tid, NULL);

// sleep(3);

return 0;

}

//g++ -o Thread_write Thread_write.cpp -lpthread