Вопрос

Я пишу небольшой пробный проект, и мне нужно пройти и объектировать тип типа Queuulist по значению нить в пул резьбы. Это Boost Threadpool, и я использую связывание, чтобы пройти аргументы на поток.

По какой-то причине я не могу пройти свой товар в теме Threadpool по значению ...

Кто-нибудь может помочь тому, что я делаю не так?

void ConsumerScheduler()
{
    int count = 0;
    typedef boost::intrusive::list<QueuList> List;
    while (true)
    {
        WaitForSingleObject(hConsumer, 2000); // Wait for hConsomuer to become > 0
        {
            //lock Queue
            QueuList *item = NULL;
            boost::mutex::scoped_lock lock(mtx);
            {//Scope of lock
                if (lst->size() == 0)
                {
                    printf("List is emtpy"); 
                    continue;
                }
                else
                {
                    List::iterator iter(lst->begin());
                    item = &*iter;
                    lst->pop_front();  //Item is removed from list, so pointer is no longer available!!!
                    printf("Popped item off list.  List current size: %d\n",lst->size());
                    count++;
                }
            }
            //Pass to threadpool
            tpp.schedule(boost::bind(taskfunc,*item)); //it will not accept *item or item in this bind function to pass it by value
            total--;
            if (total == 0)
            {
                printf("Total is now zero!\nCount is %d\n", count);
            }
            if (count == 5)
                break;

            ReleaseSemaphore(hProducer,total , NULL);  // Release the hProducer semaphore, possibly waking producer
        }
    }
}

//Thread pool thread function
void taskfunc(QueuList list)
{
    boost::mutex::scoped_lock lock(mtx);
    {
        std::string name= list.GetName();
        printf("Name gotten: %s",name);
    }

}

Причина, по которой я хочу пройти по значению, так что каждая нить ThreadPool имеет собственную копию объекта, поскольку указатель удаляется из списка первой функцией, это приведет к ошибке, если я передаю ссылку.

Это было полезно?

Решение

Вы можете решить это, используя boost::shared_ptr<QueueList> в очереди и планирование ThreadPool. Это лучше всего выражает отключение общих данных, которые вы хотите, в отсутствие unique_ptr в некоторых STLS.

Другие советы

Ошибка возникает во время выполнения или времени компиляции?

Я создаю свой собственный код и не имею компиляции ошибок.

Я не использую повышение, но, если вы получите ошибку во время выполнения, я думаю, что ошибка находится в столешке. Рабочее замок не должно быть внутри скобок?

Редактировать: у меня нет привилегий, чтобы комментировать, поэтому я разместил как ответ

Лицензировано под: CC-BY-SA с атрибуция
Не связан с StackOverflow
scroll top