Синхронизация потоков

DWORD WINAPI thread(void *argv)
{
    SOCKET s = 0;
    int rcv_size, snd_size, sz = sizeof(int);
    long ptr = 0, bytesRead = 0, p_size = MAX_BUF;

    int cnt = 0;
    char number[10];
    char *query_str;
    char *recv_str, *send_str, *szPage, *tmp;

    int exp_count = 0;
    int ovector[VECT_SIZE];
    char substring[MAX_STR];
    int matches = 0;

    int i = 0,j = 0;

    s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

    getsockopt(s, SOL_SOCKET, SO_SNDBUF, (char*)&snd_size, &sz);
    if ((send_str = (char*)malloc(snd_size)) == NULL)
        error(10);

    getsockopt(s, SOL_SOCKET, SO_RCVBUF, (char*)&rcv_size, &sz);
    if ((recv_str = (char*)malloc(rcv_size)) == NULL)
        error(10);

    closesocket(s);

    if ((szPage = (char*)malloc(MAX_BUF)) == NULL)
        error(10);

    while (1) {
        [COLOR="Red"]cnt = counter;
        if (cnt > stopCount)
            break;

        while (InterlockedExchangeAdd(&counter, 1) == cnt)
            Sleep(10);[/COLOR]

        s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
       
        connect(s, (SOCKADDR*)&sin_remote, sizeof(sin_remote));

        memset(send_str, 0, snd_size);
        strcpy(send_str, "GET http://");
        strcat(send_str, host);
        [COLOR="SeaGreen"]sprintf(number, "%d", cnt);
        query_str = substr(query, "{ID}",number);
        strcat(send_str, query_str);[/COLOR]
        free(query_str);
        strcat(send_str, " HTTP/1.0\nHost: ");
        strcat(send_str, host);
        strcat(send_str, "\nUser-Agent: ");
        strcat(send_str, agent);
        strcat(send_str, "\nAccept: */*\nAccept-Language: en-US\n\n\n");
   
        send(s, send_str, (int)strlen(send_str)-1, 0);

        memset(szPage, 0, p_size);
        ptr = 0;

        while (1) {
            memset(recv_str, 0, rcv_size);
            if ((bytesRead = recv(s, recv_str, rcv_size, 0)) <= 0)
                break;

            ptr += bytesRead;

            if (ptr >= p_size) {
                p_size += MAX_BUF;
                printf("p_size = %d\n", p_size);
                if ((tmp = realloc(szPage, p_size)) == NULL)
                    error(10);
            }

            strcat(szPage, recv_str);
        }
        closesocket(s);

        if ((matches = pcre_exec(re, NULL, szPage, ptr, 0, 0, ovector, VECT_SIZE)) <= 0)
            fputs("Not found\n", out);

        for (i = 1; i <= matches; i++) {
            memset(substring, 0, MAX_STR);
            pcre_copy_substring(szPage, ovector, matches, i-1, substring, MAX_STR);
            fprintf(out, "%s\n", substring);
        }
    }

    free(send_str);
    free(recv_str);
    free(szPage);
    return 0;
}

#define THREADS_NUM 5
           counter = startCount;
    for (i = 0; i <= stopCount; i++) {
        if (i >= THREADS_NUM) break;
        hThread = (HANDLE)_beginthreadex(NULL, 0, thread, NULL, 0, &dwThreadID);
    }

    WaitForMultipleObjects(i-1, hThread, TRUE, INFINITE);