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
