新鲜出炉Google面试题一道(多线程)

baohuaihuai

有四个线程1,2,3,4,线程1的功能就是输出1,线程2的功能就是输出2,以此类推.........
现在有四个文件.ABCD.初始都为空.
现要让四个文件呈如下格式:
A:  1 2 3 4 1 2....
B:  2 3 4 1 2 3....
C:  3 4 1 2 3 4....
D:  4 1 2 3 4 1....

设计程序.

wuxiangzhi

简单实现的话，很容易编码
考虑效率的话，就要话点心思设计调度算法

[ 本帖最后由 wuxiangzhi 于 2007-10-26 14:56 编辑 ]

baohuaihuai

原帖由 wuxiangzhi 于 2007-10-26 14:55 发表
加锁
if(具备条件)
   写之

虽然这题不是很难，不过这个基本等于没答...

cugb_cat

我想这个题应该不能让线程有阻塞。

wuxiangzhi

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <pthread.h>
#include <errno.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>

typedef struct file_node{
        int             r_pipe;
        int             w_pipe;
        int             fd;
}file_node;

char *file[] = {"./a","./b","./c","./d"};

file_node  node_list[4];

void *thread_func(void *arg);

int main()
{
        int     *num, i;
        int     sockpair[2];

        memset(node_list, 0, sizeof(node_list));

        //打开文件，构建线程间管道

        for (i=0; i<4; i++) {

                if (socketpair(AF_UNIX,SOCK_STREAM, 0, sockpair)) {
                        printf("socketpair error !\n");
                        exit(1);
                }

                node_list[i].w_pipe = sockpair[0];

                if (i != 3)
                        node_list[i+1].r_pipe = sockpair[1];
                else
                        node_list[0].r_pipe = sockpair[1];

                node_list[i].fd = open(file[i], O_CREAT | O_WRONLY| O_APPEND, S_IRUSR|S_IWUSR);
                if (node_list[i].fd < 0) {
                        printf("open fd error , exit !\n");
                        exit(1);
                }
        }
        //创建线程      

        for(i=0;i<4; i++) {
                num =(int*)malloc(sizeof(int));
                *num = i;
                pthread_create(NULL, NULL, thread_func, num);
        }

        pause();
}

void *thread_func(void *arg)
{
        pthread_t          pid;
        char               buf[100];
        int                w_fd, num;

        num = *(int*)arg;
        free(arg);
        pid = pthread_self();
        pthread_detach(pid);

        sprintf(buf, "%d", num+1);
        w_fd = node_list[num].fd;


        for (; ; )
        {
                        //写文件

                if (write(w_fd, (void*)buf, strlen(buf)) != strlen(buf)) {
                        printf("write something to file error !\n");
                        break;
                }
                //通知下一个线程写      

                if (write(node_list[num].w_pipe, (void*)&w_fd, sizeof(int)) != sizeof(int)) {
                        printf("write fd to pipe error !\n");
                        break;
                }
                if (read(node_list[num].r_pipe, &w_fd, sizeof(int)) != sizeof(int)) {
                        printf("read fd from pipe error !\n");
                        break;
                }
        }

        pthread_exit(0);
}

[ 本帖最后由 wuxiangzhi 于 2007-10-31 14:31 编辑 ]

wuxiangzhi

随便写了，效率可能不高，需要优化

xiaozhu2007

赞一下,看来google对算法的要求还是很高的

cugb_cat

原帖由 xiaozhu2007 于 2007-10-26 17:17 发表
赞一下,看来google对算法的要求还是很高的

那是相当高

wuxiangzhi

原帖由 DaYuTou 于 2007-10-26 20:26 发表
大家有没有想到lseek，就是每次写完文件后用lseek跳到3个字节之后再写文件，这样就不需要线程间的同步

貌似不能往lseek形成的空洞里写东西的吧~~