Работа с потоками

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
 
char buf1[1024], buf2[1024];
int r1, r2;
int rez = 0;
 
void* pthread_wr_file (void* p) {
    char q[15];
    sprintf(q, "%ld", (intptr_t)p);
    int f3 = open("./3", O_WRONLY|O_TRUNC|O_CREAT);
    if (write (f3, q, strlen(q)) == -1) {
        printf("error wr\n");
    }
    system("chmod 666 3");
    return NULL;
}
 
int func (int i) {
    int per = 0, g;
    for (int j = 0; buf1[i+1] != buf2[j]; j++) { g = j+3; }
    for (int j = g; buf2[j] > 47 && buf2[j] < 58; j++) { 
        per = per*10+buf2[j]-48;
    }
    return per;
}
 
void* thread_add (void* p) {
    int i = (intptr_t)p;
    rez+=func(i);
    return NULL;
}
 
void* thread_sub (void* p) {
    int i = (intptr_t)p;
    rez -= func(i);
    return NULL;
}
 
void* thread_mul (void* p) {
    int i = (intptr_t)p;
    rez*=func(i);
    return NULL;
}
 
void* thread_div (void* p) {
    int i = (intptr_t)p;
    rez/=func(i);
    return NULL;
}
 
int main() {
    int f1 = open("./1", O_RDONLY);
    int f2 = open("./2", O_RDONLY);
    if (f1 == -1 || f2 == -1) return 0;
    r1 = read(f1, buf1, 1024);
    r2 = read(f2, buf2, 1024);
    buf1[r1] = 0;
    buf2[r2] = 0;
    printf("%s\n", buf1);
    printf("%s\n", buf2);
    for (int i = 2; buf2[i] > 47 && buf2[i] < 58; i++) {
        rez = rez*10+buf2[i]-48;
    } //all znach trans to int type
 
    pthread_t t1[r1/3];
    int count_pthread = 0;
    for (int i = 0; i < r1; i++) {
        if(buf1[i] == '*') {
            if (pthread_create(&t1[count_pthread++], NULL,              thread_mul, (void*)(intptr_t)i)) {
                printf("error mul\n");
                return 0;
            }
        }
        if(buf1[i] == '/') {
            if (pthread_create(&t1[count_pthread++], NULL,              thread_div, (void*)(intptr_t)i)) {
                printf("error div\n");
                return 0;
            }
        }
    }
    for (int i = 0; i < count_pthread; i++) {
        pthread_join(t1[i], NULL); 
        pthread_detach(t1[i]);
    }
 
    for (int i = 0; i < r1; i++) {
        if (buf1[i] == '+') {
            if (pthread_create(&t1[count_pthread++], NULL,              thread_add, (void*)(intptr_t)i)) {
                printf("error add\n");
                return 0;
            }
        }
        if (buf1[i] == '-') {
            if (pthread_create(&t1[count_pthread++], NULL,              thread_sub, (void*)(intptr_t)i)) {
                printf("error sub\n");
                return 0;
            }
        }
    }
    for (int i = 0; i < count_pthread; i++) {
        pthread_join(t1[i], NULL);
        pthread_detach(t1[i]);
    }
    printf("\n--------------\nrez = %d\n", rez);
    pthread_t t2;
    if(pthread_create(&t2, NULL, pthread_wr_file, (void*)(intptr_t)rez)) {
        printf("error");
        return 0;
    }
 
    pthread_join(t2, NULL);
    pthread_detach(t2);
}
 
 
//gcc -pthread lab2.c -o 1323

//pthread_t t1[r1/3];
std::thread t1[r1/3];
 
//           if (pthread_create(&t1[count_pthread++], NULL,              thread_add, (void*)(intptr_t)i)) {
//                printf("error add\n");
//                return 0;
//            }
 
t1[count_pthread++] = std::thread(thread_add, (void*)(intptr_t)i));

    for (int i = 0; i < count_pthread; i++) {
t1[i].join();
        //pthread_join(t1[i], NULL);
        //pthread_detach(t1[i]);