courses:high_performance_computing:producer_consumer
Differences
This shows you the differences between two versions of the page.
| Both sides previous revisionPrevious revisionNext revision | Previous revision | ||
| courses:high_performance_computing:producer_consumer [2018/09/28 11:45] – kel | courses:high_performance_computing:producer_consumer [2025/02/23 14:55] (current) – odoronin | ||
|---|---|---|---|
| Line 1: | Line 1: | ||
| - | ====== | + | ====== |
| + | > [[https:// | ||
| Ваша задача - реализовать классический паттерн producer-consumer с небольшими дополнительными условиями. | Ваша задача - реализовать классический паттерн producer-consumer с небольшими дополнительными условиями. | ||
| Программа должна состоять из 3+N потоков: | Программа должна состоять из 3+N потоков: | ||
| - | - главный | + | - Главный |
| - producer | - producer | ||
| - interruptor | - interruptor | ||
| - N потоков consumer | - N потоков consumer | ||
| - | На стандартный ввод программе подается | + | В файл, чтение которого уже |
| - | * Задача producer-потока - получить на вход список чисел, и по очереди использовать каждое значение из этого списка для обновления переменной разделяемой между потоками. После этого поток должен дождаться реакции одного из consumer-потоков, | + | * Задача producer-потока - получить на вход список чисел, и по очереди использовать каждое значение из этого списка для обновления переменной разделяемой между потоками |
| - | * Задача consumer-потоков отреагировать на каждое изменение | + | * Задача consumer-потоков отреагировать на уведомление от producer |
| - | * Задача потока-interruptor проста: | + | - Функция, исполняющая код этого потока consumer_routine, должна принимать указатель на объект/переменную, из которого будет |
| - | + | - После суммирования переменной поток должен заснуть на случайное количество миллисекунд, | |
| - | Функция run_threads должна запускать | + | - Потоки consumer не должны дублировать вычисления друг с другом одних и тех же значений |
| - | + | - В качестве возвращаемого значения поток должен вернуть свою частичную посчитанную сумму | |
| - | Для обновления и получения | + | * Задача потока-interruptor проста: |
| + | * Завершение | ||
| + | * При сигнале в качестве вывода нужно выдавать | ||
| + | * В нашем producer/ | ||
| + | Функция run_threads | ||
| + | * При отсутствии входных данных ядра | ||
| Для обеспечения межпоточного взаимодействия допускается использование только pthread API. На вход приложения передаётся 2 аргумента при старте именно в такой последовательности: | Для обеспечения межпоточного взаимодействия допускается использование только pthread API. На вход приложения передаётся 2 аргумента при старте именно в такой последовательности: | ||
| - Число потоков consumer | - Число потоков consumer | ||
| - Верхний предел сна consumer в миллисекундах | - Верхний предел сна consumer в миллисекундах | ||
| + | |||
| + | В поток вывода должно попадать только результирующее значение, | ||
| + | В случае детектирования ошибок нужно выдавать не нулевой код возврата. | ||
| <file cpp> | <file cpp> | ||
| + | #include < | ||
| + | #include < | ||
| #include < | #include < | ||
| - | |||
| - | class Value { | ||
| - | public: | ||
| - | Value() : _value(0) { } | ||
| - | |||
| - | void update(int value) { | ||
| - | _value = value; | ||
| - | } | ||
| - | |||
| - | int get() const { | ||
| - | return _value; | ||
| - | } | ||
| - | |||
| - | private: | ||
| - | int _value; | ||
| - | }; | ||
| void* producer_routine(void* arg) { | void* producer_routine(void* arg) { | ||
| - | // Wait for consumer to start | + | // Wait for consumer to start. |
| + | // You should use this waiting only for debugging your code | ||
| + | // For the final solution please remove this waiting | ||
| // Read data, loop through each value and update the value, notify consumer, wait for consumer to process | // Read data, loop through each value and update the value, notify consumer, wait for consumer to process | ||
| + | std:: | ||
| + | // ... | ||
| } | } | ||
| void* consumer_routine(void* arg) { | void* consumer_routine(void* arg) { | ||
| // notify about start | // notify about start | ||
| - | // allocate value for result | + | // you should use this notification only for debugging your code |
| + | // for the final solution please remove this notification | ||
| + | |||
| + | | ||
| // for every update issued by producer, read the value and add to sum | // for every update issued by producer, read the value and add to sum | ||
| - | // return pointer to result | + | // return pointer to result |
| } | } | ||
| void* consumer_interruptor_routine(void* arg) { | void* consumer_interruptor_routine(void* arg) { | ||
| - | // wait for consumer | + | // wait for consumers |
| + | // you should use this waiting only for debugging your code | ||
| + | // for the final solution please remove this waiting | ||
| - | // interrupt consumer while producer is running | + | // interrupt |
| } | } | ||
| int run_threads() { | int run_threads() { | ||
| - | // start 3 threads and wait until they' | + | // start N threads and wait until they' |
| - | // return sum of update | + | // return |
| return 0; | return 0; | ||
courses/high_performance_computing/producer_consumer.1538124317.txt.gz · Last modified: 2018/09/28 11:45 by kel