Pimpl + std::thread + linux sockets?

Доброго времени суток.
Есть задача постоянно слушать сокеты, ну и что-то с этим всем делать, класс назван Transport.
Т.к. типы сокетов бывают разные + в конечном классе совсем не надо показывать внутренности - сделал через pimpl.
Теперь дальше, в основной программе крутится вечный цикл, и в начале каждой итерации происходит обращение к моему классу, там вызывается epoll_wait.
Хочу сделать следующее, чтобы в основной программе не вызывать постоянно функцию Transport, вынести последний в отдельный поток со своими вечным циклом. И добавить 2 очереди, одна на прием, вторая на отправку. И они должны быть обе видны из основной программы, т.е. в начале итерации цикла, программа смотрит что есть в очереди на прием, вычитывает(вынимает) сообщения, дальше в цикле где то записывает информацию в очередь на отправку. Transport в свою очередь в вечном цикле опрашивает епол, если что-то вычитал, записывает в очередь на прием и постоянно просматривает очередь на отправку, если не пустая - отправляем. Вопрос в следующем, с потоками на c++11 не работал, есть опыт только с Qt-потоками, поэтому прошу вашей помощи. Лучше весь класс запихать в поток, если только его вечный цикл? Если только цикл, как будет выглядить доступ из потока до очередей? Если весь класс, то метода положить в очередь, и получить из очереди обворачивать в мьютексы?
Ну и, как я понял, при создании потока, надо сразу сделать detach?
Заранее благодарен.

0

я бы реализовал при помощи тред-пула.

в пул добавляется задача:
ожидать сообщения, и вычитывать их.
он спит, пока не придут новые сообщения.
задача инициализируется коллбеком,
который нужно дернуть,
что бы уведомить о полученной посылке.


другой тред спит до тех пор, пока ему не закинули задачу:
отправить в сокет новое сообщение.
он закидывает. и если новых задач не накидали - засыпает.

Сообщение от Воротислав обворачивать в мьютексы?

ну дык, ежели разделяемый между тредами ресурс - конечно жеж.

1

hoggy,
Спасибо.
Ну про ресурс, я так и подумал, хотя разделение так себе, один должен писать в конец очереди, другой должен из начала вытаскивать. Ну хотя если внезапно очередь пустая, и транспорт начал писать... ну в общем, я понял.
Я думал про тред-пул, но если честно не придумал для него задач. Чтобы ожидания епола не блокировали выполнения цикла, в качестве таймаута я ему передаю 0. И следовательно, его надо либо дергать каждый раз, либо вытащить в поток. Тут мне нужен один поток, который будет крутить свой вечный цикл и обрабатывать сообщения из сети. Причем у него есть пара типов сообщений, один тип он должен сам обрабатывать, второй тип он должен положить в очередь сообщений. И тут же прочитать есть ли сообщения из очереди на запись, если есть поотправлять несколько (или все).
И всё же, не подскажите, как правильнее: один метод из класса транспорт (например ) или же весь экземпляр класса засунуть в std::thread?

0

Сообщение от Воротислав Чтобы ожидания епола не блокировали выполнения цикла

пускай блокируют.
эта задача - в отдельном потоке.
он ждёт.
сообщение получил,
коллбек дернул.
ждет дальше.

Сообщение от Воротислав И всё же, не подскажите, как правильнее: один метод из класса транспорт

мне не понятно, что за транспорт и нафиг он нужен.

у вас два потока. один отправляет по необходимости,
другой ожидает входящие.
все.
два треда.

1

hoggy,
Вы не поняли :-) Когда я спрашивал, еще не было ни тредов, ни практики, ни знаний как использовать эти треды. Я просто читал, и попутно прикидывал как буду делать.
Сегодня вынес класс по работе с сокетом в отдельный поток, и запустил там вечный цикл. В основной программе так же цикл крутится. Вроде пока всё работает. Спасибо)

0