如何使此代码作为异步程序工作

Question

今天我将实现一个非常基本的 Thread 类。我的问题是为什么这段代码会同步运行：

struct Clerk : public Thread
{
    Clerk()
    {
        IsOnService = false;
    }
    void Run()
    {
        std::deque<int> dq;
        std::cout << this->GetId() << " receive new customer " << '\n';
        for (int i = 0; i < 1000000; ++i) dq.push_front(i);
        std::cout << this->GetId() << " has finished" << '\n';

        IsOnService = false;
    }

    bool IsOnService;
};

struct Customer
{
    bool IsOnService;
};

struct Service
{
    Clerk*      clerk;
    Customer*   customer;
    Service(Clerk* c, Customer* cu)
    {
        clerk = c;
        customer = cu;
        clerk->Join();
    }
};

int main()
{
    int nClerks = 5;
    Clerk* clerks[] = { 
        new Clerk(), new Clerk(), new Clerk(), new Clerk(), new Clerk()
    };

    while (1) {
        if (GetAsyncKeyState(0x43) & 0x7FFF) {
            Customer* newCustomer = new Customer();
            for (int i = 0; i < nClerks; ++i)
                if (!clerks[i]->IsOnService) {
                    Service* newService = new Service(clerks[i], newCustomer);
                    delete newService;
                    break;
                }
        }
    }
    for (int i = 0; i < nClerks; ++i) delete clerks[i];
    return 0;
}

首先

双端队列仅用于进行需要花费数次的艰苦工作，但是当我运行上面的代码时，它需要时间，但是每个线程运行线程我的意思是当我运行它时我有这样的事情：

C:>100 receive new customer

...几次...

C:>100 has finished

C:>150 receive new customer

...几次...

C:>150 has finished

...等等

我希望拥有的行为如下：

C:>100 receive new customer

C:>150 receive new customer

C:>100 has finished

C:>150 has finished

或者类似的东西。如果有人可以帮助我。我使用 deque 是因为我想做一个需要时间的任务，但代码需要在 C++98 中编译。请不要用 C++11 或更高版本实现的代码回答我。

Answer 1

每次您将工作添加到Clerk 时

Service(Clerk* c, Customer* cu)
{
    clerk = c;
    customer = cu;
    clerk->Join();
}

从提问者的previous question 中提升Join 函数

void Thread::Join()
{
    m_handle = (HANDLE)_beginthreadex(0, 0, &this->call, 0, 0, 0);
    if (m_handle) WaitForSingleObject(m_handle, INFINITE);
}

我们可以看到调用线程停止死亡并等待Clerk的线程完成。换句话说，主线程停止，Clerk 线程运行完成，然后主线程恢复并将下一个作业排队到下一个Clerk。没有两个Clerks 会同时处于活动状态。

您需要将作业添加到Clerks 并让Clerks 运行每个Clerk 一个且只有一个线程。当没有更多工作要添加时，您可以加入Clerks。这需要对上一个问题中的 Thread 类进行相当大的重写。

你真正想要的是让自己成为thread pool of Clerks。

顺便说一下，重新考虑Service。这里不需要上课。由于 Service 是创建后立即销毁的，并且在它处于活动状态时实际上不需要维护任何状态，所以 free function 就足够了。