Подсчет символов из файла с помощью дополнительного потока

#include <unistd.h>
#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <errno.h>
#define BUFSIZE 1
void* write_thread (void*);
void* read_thread (void*);
char buffer[BUFSIZE];
int isexit = 0;
int x;
pthread_mutex_t my_sync; // Инициализируем мьютекс
 
void print (const char * x)
{
printf("\t%s\n", x);
}
 
int main ()
{
pthread_t tid1, tid2; // Инициализация потоков
pthread_mutex_init (&my_sync, NULL); // Инициализация мьютекса
pthread_create (&tid1, NULL, write_thread, (void *) NULL); // Создаем поток записи
pthread_create (&tid2, NULL, read_thread, (void *) NULL); // Создаем поток чтения
pthread_join (tid1, NULL); // Ждем завершения потоков
pthread_join (tid2, NULL);
}
void* write_thread (void* dummy) // Функция записи
{
FILE * fd = fopen("file2_.txt", "r");
if (fd == NULL)
{
print("Ошибка при открытии файла");
return 0;
}
print("Происходит запись в память");
while(!feof(fd))
{
<--- здесь нужно ждать первый мьютекс
pthread_mutex_lock(&my_sync); // Захватываем мьютекс — здесь захватывай первый мьютекс
int w = 0;
while((w<BUFSIZE) && (!feof(fd)))
{
buffer[w] = fgetc(fd);
w++;
}
if ((feof(fd)) && (w<BUFSIZE)) buffer[w] = '\0';
pthread_mutex_unlock(&my_sync); // Освобождаем мьютекс — здесь освобождай 2й мьютекс
usleep(x);
}
fclose(fd);
isexit = 1;
return;
}
 
void* read_thread (void* dummy) // Функция чтения
{
print("Обработка данных");
int s = 0;
int t = 0;
for (;;)
{
<--- здесь нужно ждать второй мьютекс
pthread_mutex_lock(&my_sync); // Захватываем мьютекс — здесь захватывай второй мьютекс
int i = 0;
int CountOfSpace = 0;
while((i<BUFSIZE) && (buffer[i]!= '\0'))
{ 
printf ("%c", buffer[i]);
if (buffer[i] == '\n')
{
CountOfSpace++;
}
i++;
}
s = s + CountOfSpace;
t = t + i;
pthread_mutex_unlock (&my_sync); // Освобождаем мьютекс — здесь освобождай 1й мьютекс
usleep(x);
if(isexit == 1)
break;
}
printf("Количество символов в файле:%d\n", t);
printf("Количество строк в файле:%d\n", s);
return;
}