#include <pthread.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/types.h>  /* See NOTES */
#include <sys/socket.h>
#define SOCKET_BUFFER_SIZE (32768U)


/* 參考:
 * frameworks\native\libs\input\InputTransport.cpp
 */

/* 線程1函數(shù)實現(xiàn) */
 void *function_thread1 (void *arg)
 {
 int fd = (int)arg;/* 把文件句柄轉(zhuǎn)換出來 */
 char buf[500];
 int len;
 int cnt = 0;

 while (1)
 {
 /* 向 main線程發(fā)出: Hello, main thread */
 len = sprintf(buf, "Hello, main thread, cnt = %d", cnt++);
 write(fd, buf, len);

 /* 讀取數(shù)據(jù)(main線程發(fā)回的數(shù)據(jù)) */
 len = read(fd, buf, 500);
 buf[len] = '\0';
 printf("%s\n", buf);

 /* 延時5秒鐘 */
 sleep(5);
 }

 return NULL;
 }



 int main(int argc, char **argv)
 {
 int sockets[2];

 /* 使用 socketpair 得到兩個文件句柄到數(shù)組sockets */
 socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets);

 /* 設(shè)置緩沖區(qū), 每個文件句柄對應(yīng)兩個緩沖區(qū)，兩個文件對應(yīng)四個 */
 int bufferSize = SOCKET_BUFFER_SIZE;
 setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));
 setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));
 setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));
 setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));

 /* 創(chuàng)建線程1(thread1),并把文件句柄sockets[1]傳給子線程thread1 */
 pthread_t threadID;
 pthread_create(&threadID, NULL, function_thread1, (void *)sockets[1]);

 char buf[500];
 int len;
 int cnt = 0;
 int fd = sockets[0];/* 當前main函數(shù)的文件句柄是sockets[0] */


 while(1)
 {
 /* 讀數(shù)據(jù): 讀線程1發(fā)出的數(shù)據(jù) */
 len = read(fd, buf, 500);
 buf[len] = '\0';
 printf("%s\n", buf);

 /* main thread向thread1 發(fā)出: Hello, thread1 */
 len = sprintf(buf, "Hello, thread1, cnt = %d", cnt++);
 write(fd, buf, len);
 }
 }