0

我正在编写一个带有类、pthreads、互斥锁和 conds 的简单理发店 C/C++ 项目，但是当我在循环中创建一个新的客户对象时遇到了一个问题：

void BarberShop::simulate() {
barber.start(); // start the barber
int custId = 1;
while(1) {
    Customer c(custId, *this);
    customers.push_back(c);
    c.start();
    sleep(3);
    custId++;
}

}

void Customer::start() {
    pthread_create(&thread, NULL, &Customer::run, this);
}

void* Customer::run(void *ptr) {
    Customer* data = reinterpret_cast<Customer*>(ptr);
    while(1) {
        printf("Customer %d running...\n", data->id);
        sleep(3);
    }
}

当我运行这个程序时，它会很好地创建线程，但是每当我创建一个新线程时，它都会覆盖其他线程中的 id。输出：

Customer 1 running... 1 sec
Customer 1 running... 2 sec
Customer 1 running... 3 sec
Customer 2 running... 4 sec
Customer 2 running... 4 sec

在循环中我说：

Customer c(...);

这不会在每次循环迭代时创建一个新实例吗？为什么后续线程会覆盖它？

更新

class Customer
{
private:
    pthread_t thread;
    pthread_cond_t cond;
    pthread_mutex_t mutex;
    static void* run(void *args);
    int id;
    BarberShop *bs;
public:
    Customer(int _id, BarberShop &_bs);
    ~Customer();
    void start();
}; 

Customer::Customer(int _id, BarberShop &_bs) {
id = _id;
bs = &_bs;
}

更新 2：使用 pthread id

Customer 1 running...[3066383168]
Customer 2 running...[3057990464]
Customer 2 running...[3057990464]
Customer 3 running...[3049597760]
Customer 3 running...[3049597760]
Customer 3 running...[3049597760]
Customer 3 running...[3049597760]
Customer 4 running...[3049597760]
Customer 4 running...[3041205056]
Customer 4 running...[3041205056]
Customer 4 running...[3041205056]
Customer 5 running...[3041205056]
Customer 4 running...[3041205056]
Customer 5 running...[3032812352]
Customer 5 running...[3032812352]
4

2 回答 2

2

基于堆栈的自动对象和多线程是错误的......“在所有情况下都不和谐”:)

正如 Casey 所建议的，您可以使用 Customer* 的向量。如果要通过引用将对象传递给线程，请使用 new 动态分配它们。这解决了同步对象的不可复制性等问题，并确保每个线程都有自己的*对象。线程获得所有权，如果它需要在进程终止之前终止，则需要删除传递的 *object。

或者，vector::emplace 将 Customer 对象放入向量中，以便自动/堆栈 Customer 消失。

于 2013-07-19T17:46:45.287 回答
1

在接下来的片段中

while(1) {
    Customer c(custId, *this);
    customers.push_back(c);
    c.start();
    sleep(3);
    custId++;
}

类实例c在 while 循环的范围内是本地的。在循环的每次迭代结束时，c被销毁。

因此，当您执行该类customers.push_back(c)的副本时（请参阅（默认）复制构造函数）并添加到客户列表中。这意味着当您执行c.start()推送到向量上的副本时，尚未启动，只有循环本地的实例。在循环的循环迭代结束时，循环c被破坏。循环再次开始并c创建一个新的。

编辑：请参阅 Martin James 和 Casey 关于您所看到的行为发生的原因的评论

于 2013-07-19T16:35:17.493 回答