1.10 编程之美-凯发真人娱乐

//writes a block to hard disk
bool writeblocktodisk(block *in_block);

class thread
{
public:
    thread(void (*work_func)());
    ~thread();
    void start();
    void abort();
};

class semaphore
{
public:
    semaphore(int count, int max_count);
    ~semaphore();
    void unsignal();
    void signal();
};

class mutex
{
public:
    waitmutex();
    releasemutex();
};
//----------------------------------------------------

//1.确定使用信号量，而非互斥量，保证并行操作
//2.当缓冲区并不满并且下载没结束时，下载线程运行
//3.当缓冲区并不空并且下载没结束时，存储线程运行

//缓冲区数组，模拟循环队列
block g_buffer[max_count];
thread g_download(proca);
thread g_write(procb);

//一开始缓冲区空间为max_count，整个缓冲区可供下载的数据填充
semaphore fordownload(max_count, max_count);
//一开始缓冲区无数据可供存储
, max_count);

//下载任务是否完成
bool isdone;
//下载的数据从缓冲区的哪个地方开始填充
int in_index;
//存储的数据从缓冲区的哪个地方开始提取
int out_index;

void proca()
{
    while(true)
    {
        //首先取得一个空闲空间，以便下载数据填充
        fordownload.unsignal();
        //填充
        isdone = getblockfromnet(g_buffer   in_index);
        //更新索引
) % max_count;
        //提示存储线程可以工作
        forwrite.signal();

//当任务全部下载完成，进程就可以结束了
        if(isdone)
            break;
    }
}

void procb()
{
    while(true)
    {
        //查询时候有数据可供存储
        forwrite.unsignal();
        //存储
        writeblocktodisk(g_buffer   out_index);
        //更新索引
) % max_count;
        //将空闲空间还给缓冲区
        fordownload.signal();

//当任务全部下载完成，并且所有的数据都存储到硬盘中，进程才可以结束
        if(isdone && in_index == out_index)
            break;
    }
}

int main()
{
    isdone = false;
    in_index = ;
    out_index = ;
    g_download.start();
    g_write.start();
}