Переписать процесс в поток

//клиент для сервера интерактивных команд
void ClientIntServ(char **env)
{
//      printf("Client s0\n");
    char bufs0[MAXLINE];  
    pid_t ex;
    int n;
 
    p=0;
    // цикл по интерактивным командам
    while (queue0[p]!=NULL)
    {
        // запись очередной команды в массив cmd
        snprintf(cmd, sizeof(cmd), "%s", queue0[p]);
        p++;
 
        // bufs0 = cmd;
        // MAXLINE = strlen(cmd);
        
        // fd_1=dup(1); 
        // fd_0=dup(0);
        // создание рабочего процесса
        if((ex = fork()) == 0)
        {
            in_out = str_parse(cmd);    //разбор строки команды
            
            // Выполнение команд – исполнимых файлов
            if(execvp(arg[0], arg) == -1)
            {
 
                // Выполнение встроенных в оболочку команд
                if (!strcmp(arg[0], "showenv"))
                {
                    int i;
                    printf("\nEnvironment:\n");
                    for (i=0; env[i] != NULL; i++) 
                        printf("\n%s", env[i]);
                    printf("\n");
                }
                else                        
                    printf("I MySh: command < %s > not found!\n",arg[0]);                       
            }
            // завершение рабочего процесса
            printf("I Pid [%d] is Dying\n", ex);
            exit(0); 
        }             
        waitpid(ex,NULL,0);
            printf("I Pid [%d] is Dead\n", ex);
 
    }
    printf("ClientInt End\n");
}

//клиент для сервера неинтерактивных команд
void ClientNoIntServ()
{   
    p=0;  // индекс команды
    i=0;  // индекс потока
    int k;
    printf("Client s1\n");
    // Инициализация флагов
    for (k = 0; k<3; k++){
        flag[k] = 0; 
        flag1[k] = 0;
    }
    nflags = 0;
 
    // цикл по неинтерактивным командам
    while (queue[p]!=NULL) {
        // запись очередной команды в массив cmd
        snprintf(cmd, sizeof(cmd), "%s", queue[p]);
        p++;
        // Удаление символа & из команды
        for(k=0; k<MAXLEN; k++) { 
            if ((cmd[k] == '&')) {
                cmd[k]= '\0';
                break;
                }
            }
        // команда для потока с индексом i
        t_cmd[i]=strdup(cmd); // подготовлена команда
        flag[i] = 1;  // запущена потоковая функция
        flag1[i] = 1; // создана среда потока в ядре
        nflags++;  // счетчик запущенных потоков
        switch(i){
            case 0:
                pthread_create (&t_id[0], NULL, &pt_func0, NULL);
                break;
            case 1:
                pthread_create (&t_id[1], NULL, &pt_func1, NULL);
                break;
            case 2:
                pthread_create (&t_id[2], NULL, &pt_func2, NULL);
                break;
            }
        i++;
        if(i==3) break; // запущены все потоки 
        }
 
    if (i<3){ // список команд исчерпан
        for (k = 0; k<p; k++){
                pthread_join(t_id[k], NULL);
                flag1[k] = 0; // поток завершен в ядре
                nflags--;
                }
        }
    else{
        if (queue[p]!=NULL){
                while (queue[p]!=NULL) {
                    sleep(1);
                    // запись очередной команды в массив cmd
                    snprintf(cmd, sizeof(cmd), "%s", queue[p]);
                    // Удаление символа & из команды
                    for(k=0; k<MAXLEN; k++) { 
                        if ((cmd[k] == '&')) {
                            cmd[k]= '\0';
                                break;
                            }
                        }
                    // Ищем поток, который завершился
                    for (k = 0; k<3; k++){
                        if (!flag[k] && flag1[k]){  // потоковая функция завершилась 
                            pthread_join(t_id[k], NULL);
                            flag1[k] = 0; // поток завершен в ядре
                            nflags--;
                            break;
                            }
                        }
                    if (k<3){ 
                        // команда для потока с индексом k
                        t_cmd[k]=strdup(cmd); // подготовлена команда
                        flag[k] = 1;  
                        flag1[k] = 1;
                        nflags++;
                        switch(k){
                            case 0:
                                pthread_create (&t_id[0], NULL, &pt_func0, NULL);
                                break;
                            case 1:
                                pthread_create (&t_id[1], NULL, &pt_func1, NULL);
                                break;
                            case 2:
                                pthread_create (&t_id[2], NULL, &pt_func2, NULL);
                                break;
                            }
                        p++;
                        }               
                    }
                }
        }
    while (nflags) {
        // Ищем поток, который завершился
        for (k = 0; k<3; k++){
            if (!flag[k] && flag1[k]){  // поток завершился  
                    pthread_join(t_id[k], NULL);
                    flag1[k] = 0; // поток завершен в ядре
                    nflags--;
                    }
            }
        }
    printf("ClientNoInt End\n");
    return;
} 
 
// потоковая функция
void *pt_func0(void *arg)
{
    system (t_cmd[0]);
    flag[0] = 0;
    return NULL;
}
 
// потоковая функция
void *pt_func1(void *arg)
{
    system (t_cmd[1]);
    flag[1] = 0;
    return NULL;
}
 
// потоковая функция
void *pt_func2(void *arg)
{
    system (t_cmd[2]);
    flag[2] = 0;
    return NULL;
}