Differences

This shows you the differences between two versions of the page.

--- courses:high_performance_computing:producer_consumer [2020/05/03 12:25] – kel
+++ courses:high_performance_computing:producer_consumer [2021/10/04 08:00] – kel
@@ Line 1: / Line 1: @@
-====== Использование pthread API ======
+====== Posix threads ======
 Ваша задача - реализовать классический паттерн producer-consumer с небольшими дополнительными условиями.
 Программа должна состоять из 3+N потоков:
-  - главный
+  - Главный
   - producer
   - interruptor
   - N потоков consumer
-На стандартный ввод программе подается строка - список чисел, разделённых пробелом (читать можно до конца ввода). Длина списка чисел не задаётся - считывание происходит до перевода каретки.
+В файл, чтение которого уже реализовано в шаблоне кода в блокирующкем режиме, пишется список чисел, разделённых пробелом (читать можно до переноса строки). Длина списка чисел не задаётся - считывание происходит до перевода каретки.
   * Задача producer-потока - получить на вход список чисел, и по очереди использовать каждое значение из этого списка для обновления переменной разделяемой между потоками
   * Задача consumer-потоков отреагировать на уведомление от producer и набирать сумму полученных значений. Также этот поток должен защититься от попыток потока-interruptor его остановить. Дополнительные условия:
@@ Line 14: / Line 14: @@
     - В качестве возвращаемого значения поток должен вернуть свою частичную посчитанную сумму
   * Задача потока-interruptor проста: пока происходит процесс обновления значений, он должен постоянно пытаться остановить случайный поток consumer (вычисление случайного потока происходит перед каждой попыткой остановки). Как только поток producer произвел последнее обновление, этот поток завершается.
+  * Завершение приложения происходит или при считывании перевода каретки из файла или по посылке сигнала SIGTERM, обработку которого нужно также добавить. В случае, если в этот момент поток, читающий данные с файла, находится в режиме блокирующего чтения, - он также должен корректно завершиться.
 Функция run_threads должна запускать все потоки, дожидаться их выполнения, и возвращать результат общего суммирования.
@@ Line 21: / Line 21: @@
   - Верхний предел сна consumer в миллисекундах
+Так-же необходимо реализовать поддержку ключа --debug, при использовании которого каждый consumer-поток будет выводить пару (thread id, partial summ). Вывод значений psum происходит при каждом изменении.
-Так-же необходимо реализовать поддержку ключа --debug, при использовании которого каждый consumer-поток будет выводить пару (tid, psum), где tid реализуется с помощью функции get_tid(), а psum это сумма которую посчитал поток. Вывод значений psum происходит при каждом изменении.
-Функция get_tid() возвращает идентификатор потока. Идентификатор потока это не проста pthread_self(), а уникальное для каждого потока число в диапозоне от 1 .. 3+N. Значение этого числа предполагается хранить в TLS. Память под сохраняемое значение должно выделяться в heap, а указатель на него в TLS. Так-же функция get_tid должна быть самодостаточной (для использования ее в другом проекте должно быть достаточно только скопировать get_tid и использовать)
 В поток вывода должно попадать только результирующее значение, по умолчанию никакой отладочной или запросной информации выводиться не должно.
@@ Line 30: / Line 27: @@
 <file cpp>
 #include <pthread.h>
+void read_values() {
+  FILE* file = fopen("in.txt");
+  ... read();
+}
 void* producer_routine(void* arg) {
@@ Line 53: / Line 55: @@
   // return aggregated sum of values
-  return 0;
-}
-int get_tid() {
-  // 1 to 3+N thread ID
   return 0;
 }