Как я могу связаться с производителем и потребителем в обоих направлениях?

Question

Я хотел бы, чтобы рабочий поток подождал команды, сделайте это, а затем отправьте результат обратно вызывающему. Это отличается от обычной проблемы производителя/потребителя из-за ответа.

Это то, что я имею в виду:

main 
{ 
construct workers 
push to shared input buffers 
notify workers 
wait 
print results from shared output buffer 
} 

worker 
{ 
wait 
read from shared input buffer 
do work 
notify main 
} 

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

(я использую C++, если это уместно)

Answer 1

Вы на правильном пути, но вы можете упростить вещи немного и устранить необходимость сигнализировать или ждать сигнала

main 
{ 
    push to shared input buffers 
    construct workers // create and immediately run. No need for signal 
    while more workers 
     join worker // will block until worker thread exits 
    print results from shared output buffer 
} 

worker 
{ 
    read from shared input buffer 
    do work 
} 

В зависимости от того, как вы разделяете общий буфер или не разбиваете на разделы, вам может потребоваться защитить его от одновременной записи.