Multithreading+pipes

#include <stdio.h>
#include <stdlib.h>
 
#include <pthread.h>
#include <unistd.h>
 
void write_func();
void read_func();
 
int fds[2];
 
int main()
{
    pthread_t write_thread,read_thread;
 
    pthread_create (&write_thread, NULL, (void *)&write_func, NULL);
    pthread_create (&read_thread, NULL, (void *)&read_func, NULL);
 
    pthread_join (write_thread, (void*) NULL);
    pthread_join (read_thread, (void*) NULL);   
 
    return 0;
}
 
void write_func()
{
    FILE* stream;
    const char *message="Hello,world! It's pipe!\n";
    int count=5,rtn;
 
    printf("Write started...\n");
    rtn=pipe(fds);
    if(0!=rtn){
        perror("pipe failed");
        exit(EXIT_FAILURE);
    }
            
    close (fds[0]);
    stream = fdopen(fds[1], "w");
    for (;count>0;--count) {
        fprintf (stream, "%s\n", message);
        printf("Write:%s",message);
        fflush (stream);
        sleep (1);
    }       
    close (fds[1]);
    printf("End of write.\n");
}
 
void read_func()
{
    FILE* stream;
    char buffer[1024];
        
    printf("Read started...\n");    
    close (fds[1]);
    stream = fdopen (fds[0], "r");
    if(stream==NULL){
        perror("Read failed");
        exit(EXIT_FAILURE);
    }
    while (!feof (stream) && !ferror (stream) && fgets (buffer, sizeof (buffer), stream) != NULL)
        fputs (buffer, stdout);
    close (fds[0]);
    printf("End of read.\n");
}