Передача данных между каналами.Почему потоки зависают?

#include <windows.h>
#include <stdlib.h>
#include <time.h>
#include <dos.h>
#include <iostream>
#include <conio.h>
#include <math.h>
#define n 20
using namespace std;
class channel                               // класс каналов
{
    double *buf;                         // буфер для передачи данных
    int size;                            // размер буфера
    HANDLE s,
        empty,                               // семафоры
        full;
    int countr, countw;                  // указатели для чтения и записи
public:
    channel(int nn) : size(nn)           // конструктор
    {
        buf = new double[nn];          // память для буфера
        countr = 0; countw = 0;
        s = CreateSemaphore(NULL, 1, 1, NULL); // создание семафоров
        empty = CreateSemaphore(NULL, nn, nn, NULL);
        full = CreateSemaphore(NULL, 0, nn, NULL);
    }
    void operator << (double d)              // операция записи в канал
    {
        WaitForSingleObject(empty, INFINITE);   // ожидание свободных мест
        WaitForSingleObject(s, INFINITE);
        buf[countw++] = d;                        // запись в очередь
        if (countw == size) countw = 0;
        ReleaseSemaphore(s, 1, NULL);
        ReleaseSemaphore(full, 1, NULL);          // увеличение числа запи-сей
    }
    void operator >> (double& d)          // операция чтения из канала
    {
        WaitForSingleObject(full, INFINITE); // ожидание данных
        WaitForSingleObject(s, INFINITE);
        d = buf[countr]; countr++;           // чтение из циклической очереди
        if (countr == size) countr = 0;
        ReleaseSemaphore(s, 1, NULL);
        ReleaseSemaphore(empty, 1, NULL);     // увеличение числа свободных мест
    }
};
 
channel *pc[n];
DWORD WINAPI Mult(LPVOID)         // поток для умножения
{
    int j;
    double d1, d2;
    for (j = 0; j<n; j++)              // цикл
    {
        *pc[0] >> d1; *pc[1] >> d2;    // прием данных из каналов 0 и 1
        *pc[4] << (d1*d2);           // умножение и отправление в канал 4
                                     //cout << "0 = " << d1 << " 1 = " << d2 << " *4: " << (d1 * d2)<<endl;
    }
    return 1;
}
DWORD WINAPI Sinus(LPVOID)        // поток для вычисления синуса
{
    int j;
    double d1;
    for (j = 0; j<n; j++)              // цикл
    {
        *pc[4] >> d1;                // прием из канала 4
        *pc[6] << sin(d1);           // передача в канал 7
                                     //cout << "4 = " << d1 << " sin6: " << sin(d1) << endl;
    }
    return 1;
}
 
DWORD WINAPI Sinus2(LPVOID)      // второй поток для вычисления синуса
{
    int j;
    double d1;
    for (j = 0; j<n; j++)             // цикл
    {
        *pc[5] >> d1;               // прием из канала 5
        *pc[7] << sin(d1);          // передача в канал 8
                                    //cout << "5 = " << d1 << " sin7: " << sin(d1) << endl;
    }
    return 1;
}
 
DWORD WINAPI Plus(LPVOID)        // поток для сложения
{
    int j;
    double d1, d2;
    for (j = 0; j<n; j++)             // цикл
    {
        *pc[2] >> d1; *pc[3] >> d2;   // прием из каналов 6 и 7
        *pc[5] << (d1 + d2);          // передача суммы в канал 9
                                      //cout << "2 = " << d1 <<" 3 = "<<d2<< " +5: " << (d1 + d2) << endl;
    }
    return 1;
}
DWORD WINAPI Expo(LPVOID)        // поток для вычисления экспоненты
{
    int j;
    double d1;
    for (j = 0; j<n; j++)             // цикл
    {
        *pc[7] >> d1;               // прием из канала 8
        *pc[8] << exp(d1);         // передача в канал 10
                                   //cout << "7 = " << d1<<" expo8: "<<exp(d1) << endl;
    }
    return 1;
}
 
void main()                      // главный поток
{
    
    channel c[9] = {9,9,9,9,9,9,9,9,9};
    // инициализация каналов
 
    int i;                      // каждый из них состоит из 10 элементов
    for (i = 0; i<9; i++) pc[i] = &c[i];  // указатели на каналы
    CreateThread(NULL, 0, Plus, 0, 0, 0);
    CreateThread(NULL, 0, Mult, 0, 0, 0);   // запуск потоков
    CreateThread(NULL, 0, Sinus, 0, 0, 0);
    CreateThread(NULL, 0, Sinus2, 0, 0, 0);
    CreateThread(NULL, 0, Expo, 0, 0, 0);
    double u=0,v=0,x=0,y=0;
        for (i = 0; i<n; i++)
        {
            u = i; v = i + 1;
            c[0] << u; 
            c[1] << v;             // запись в каналы 0,1,2,3
            c[2] << u;
            c[3] << v;
        }
 
        for (i = 0; i<n; i++)
        {
            u = i; v = i + 1;
            c[6] >> x; c[8] >> y; cout << "\n" << i << ") " << x; // чтение и вывод результатов
            cout << " == ";
            cout << (double)(sin(u*v)); // сравнение со значениями
            cout << " " << y << " == " << (double)(exp(sin(u + v))); // исходных формул                                                                                                                 
        }
    _getch();
}