3

我正在学习并发编程，我想做的是有一个类，它负责运行自己的 Boost:Thread 的每个对象。我对这段代码有点不知所措，因为它使用了很多我不太熟悉的功能（动态分配的内存、函数指针、并发等）。就像每一行代码我都必须检查一些参考资料才能让它正确。

（是的，所有分配的内存都包含在实际代码中！）

我在使用互斥锁时遇到了问题。我将它声明为静态，并且它似乎为所有实例获得了相同的值（应该如此）。该代码仍然不是线程安全的。

互斥锁应该阻止线程（对吗？）继续前进，以防其他人锁定它。因为互斥锁是有范围的（一种简洁的功能），并且它在 if 语句中应该查看其他线程，不是吗？我仍然得到控制台输出，这清楚地表明它不是线程安全的。

另外我不确定我是否使用了静态变量。我尝试了不同的引用方式（Seller::ticketSaleMutex），但唯一有效的是“this->ticketSaleMutex”，它看起来很阴暗，似乎违背了它是静态的目的。

卖家.h：

class Seller
{
public:     
    //Some vaiables
private:
    //Other variables
    static boost::mutex ticketSaleMutex;      //Mutex definition
};

卖家.cpp：

boost::mutex Seller::ticketSaleMutex;         //Mutex declaration

void Seller::StartTicketSale()
{
    ticketSale = new boost::thread(boost::bind(&Seller::SellTickets, this));

}
void Seller::SellTickets()
{
    while (*totalSoldTickets < totalNumTickets)
    {
        if ([Some time tick])
        {
            boost::mutex::scoped_lock(this->ticketSaleMutex);
            (*totalSoldTickets)++;
            std::cout << "Seller " << ID << " sold ticket " << *totalSoldTickets << std::endl;
        }

    }
}

主.cpp：

int main(int argc, char**argv)
{
    std::vector<Seller*> seller;
    const int numSellers = 10;
    int numTickets = 40;
    int *soldTickets = new int;
    *soldTickets = 0;
    for (int i = 0; i < numSellers; i++)
    {
        seller.push_back(new Seller(i, numTickets, soldTickets));
        seller[i]->StartTicketSale();
    }
}
4

1 回答 1

12

这将创建一个立即销毁的临时文件：

boost::mutex::scoped_lock(this->ticketSaleMutex);

导致没有同步。您需要声明一个变量：

boost::mutex::scoped_lock local_lock(this->ticketSaleMutex);
于 2012-07-24T21:24:37.047 回答