С++ под Linux, процессы fork() и каналы

int fd[2];
    char s[100];
    if(pipe(fd)<0)
    {
        printf("Не удалось создать кaнал!");
        return 0;
    }
    if(fork()==0)
    {
        entry_period(A,B);
        write(fd[1],&A,sizeof(int));
        write(fd[1],&B,sizeof(int));
        return 1;
    }
    read(fd[0],&A,sizeof(int));
    read(fd[0],&B,sizeof(int));
    wait(0);

void entry_period(int &A, int &B)
{
    printf("Введите промежуток од А до B: ");
    scanf("%d %d", &A,&B);
}

printf("\nВведите колличество С-элементов ");
    scanf("%d",&c);
    if(fork()==0)
    {
        
        //C=input_C_elements(c,A,B,amount);
        //write(fd[1],&amount,sizeof(int));
        C=new int[c];
        printf("\nВведите С-элементы:\n");
        for(int i=0;i<c;i++)
        {
            printf("Введите %d С-элемент ", i+1);
            scanf("%d",&C[i]);  
            write(fd[1],&C[i],sizeof(int));
            if(C[i]>=A && C[i]<=B)
            {
                amount++;
            }
        }
        write(fd[1],&amount,sizeof(int));
        return 1;
    }
    read(fd[0],&amount,sizeof(int));
    for(int i=0;i<amount;i++)
    {
        read(fd[0],&C[i],sizeof(int));
    }

#include <mutex>
#include <thread>
#include <vector>
#include <iostream>
 
std::mutex g_cout_mutex; 
 
void print_average(const std::vector<int>& array)
{
    int sum = 0;
    for (auto it = array.begin(); it != array.end(); ++it)
        sum += *it;
 
    std::lock_guard<std::mutex> lock(g_cout_mutex);
    std::cout << "thread id: " << std::this_thread::get_id().hash() 
              << " average: "  << sum / array.size() << std::endl;
}
 
int main()
{
    int count = 0;
        
    std::cout << "enter arrays count: " << std::endl;
    std::cin >> count;
 
    std::vector<std::vector<int>> arrays;
    for (int i = 0; i < count; ++i)
    {
        int size = 0;
        std::cout << "enter array size: " << std::endl;
        std::cin >> size;
 
        if (size != 0)
        {
            std::cout << "enter array: " << std::endl;
 
            std::vector<int> array;
            for (int j = 0; j < size; ++j)
            {
                int value ;
                std::cin >> value;
 
                array.push_back(value);
            }
 
            arrays.push_back(std::move(array));
        }
    }
 
    std::vector<std::thread*> threads;
    for (auto& it : arrays)
        threads.push_back(new std::thread(print_average, std::ref(it)));
 
    for (auto& it : threads)
    {
        it->join();
        delete it;
    }
 
    std::cin.get();
    std::cin.get();
 
    return 0;
}