# Практика. Конвейер задач ## Описание проекта Задача состоит из двух частей: — Написать функцию `executePipeline`. Она должна обеспечивать конвейерный запуск функций-воркеров `job`. Выход первого воркера является входом для второго воркера, а выход второго — входом для третьего и т.д. — Написать функции-воркеры: `encryptAndCompress`, `multiEncrypt` и `generateResult`. Они делают саму работу. Воркеры должны использовать следующие функции: `encrypt` шифрует, `compress` сжимает. Они находятся в файле `common.go`. Необходимо **реализовать расчет** со следующей цепочкой: — На вход в канал `in` воркеру `encryptAndCompress` последовательно подаются некоторые строки `data`. — Воркер `encryptAndCompress` выполняет часть своей работы и шлет результат `dataChunk` в канал `out`. — Воркер `multiEncrypt` встречает данные `dataChunk` из канала `in`. Этот же канал является `out` для `encryptAndCompress`. — Аналогично `generateResult` получает данные из `in` и пишет в `out`. Получается такая последовательность: ``` ... -> encryptAndCompress -> multiEncrypt -> generateResult -> ... ``` **Вот что делают сами воркеры.** Функция `encryptAndCompress` считает значение `encrypt(data)+"~"+encrypt(compress(data))`. Это конкатенация двух строк через тильду `~`. Функция `multiEncrypt` считает значение `encrypt(th+dataChunk)`. Здесь `th=0..5` — цифра в соответствующем диапазоне, приведенная к строке. На выходе `multiEncrypt` — конкатенация результатов в порядке расчета. Функция `generateResult` [сортирует](https://golang.org/pkg/sort/) строки по возрастанию, объединяет отсортированный результат через символ нижнего подчеркивания `_` в одну строку. **Ограничения:** —  `compress` может одновременно вызываться только 1 раз, считается 10 мс. Если одновременно запустится несколько — будет задержка на 1 с. — `encrypt` считается 1 с. — На все расчеты у нас 3 с. Таким образом, необходимо написать код, который выполняется параллельно. Код писать в `worker.go`. В этот файл не надо добавлять ничего из `common.go`. Это один пакет. ## Пример Результаты, которые выводятся, если отправить воркерам `2` значения — закомментировано в тесте: ``` encryptAndCompress data apple encryptAndCompress compress a1p2l1e1 encryptAndCompress encrypt(data) EAcVHhE= encryptAndCompress encrypt(compress(data)) EEYVQBhIFEY= encryptAndCompress result EAcVHhE=~EEYVQBhIFEY= multiEncrypt dataChunk EAcVHhE=~EEYVQBhIFEY= multiEncrypt encrypt(th+dataChunk) 0 QTIkESIxGTJYDDE8KCE0MBwwNzI8Tw== multiEncrypt encrypt(th+dataChunk) 1 QDIkESIxGTJYDDE8KCE0MBwwNzI8Tw== multiEncrypt encrypt(th+dataChunk) 2 QzIkESIxGTJYDDE8KCE0MBwwNzI8Tw== multiEncrypt encrypt(th+dataChunk) 3 QjIkESIxGTJYDDE8KCE0MBwwNzI8Tw== multiEncrypt encrypt(th+dataChunk) 4 RTIkESIxGTJYDDE8KCE0MBwwNzI8Tw== multiEncrypt encrypt(th+dataChunk) 5 RDIkESIxGTJYDDE8KCE0MBwwNzI8Tw== multiEncrypt result QTIkESIxGTJYDDE8KCE0MBwwNzI8Tw==QDIkESIxGTJYDDE8KCE0MBwwNzI8Tw==QzIkESIxGTJYDDE8KCE0MBwwNzI8Tw==QjIkESIxGTJYDDE8KCE0MBwwNzI8Tw==RTIkESIxGTJYDDE8KCE0MBwwNzI8Tw==RDIkESIxGTJYDDE8KCE0MBwwNzI8Tw== encryptAndCompress data orange encryptAndCompress compress o1r1a1n1g1e1 encryptAndCompress encrypt(data) HgUEHBMc encryptAndCompress encrypt(compress(data)) HkYXQxVIH0YCQxFI encryptAndCompress result HgUEHBMc~HkYXQxVIH0YCQxFI multiEncrypt dataChunk HgUEHBMc~HkYXQxVIH0YCQxFI multiEncrypt encrypt(th+dataChunk) 0 QT8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= multiEncrypt encrypt(th+dataChunk) 1 QD8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= multiEncrypt encrypt(th+dataChunk) 2 Qz8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= multiEncrypt encrypt(th+dataChunk) 3 Qj8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= multiEncrypt encrypt(th+dataChunk) 4 RT8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= multiEncrypt encrypt(th+dataChunk) 5 RD8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= multiEncrypt result QT8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=QD8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=Qz8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=Qj8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=RT8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=RD8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4= generateResult QT8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=QD8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=Qz8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=Qj8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=RT8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=RD8CJzExMzoGDDwSKC80CiIwOUc8MSUBNz4=_QTIkESIxGTJYDDE8KCE0MBwwNzI8Tw==QDIkESIxGTJYDDE8KCE0MBwwNzI8Tw==QzIkESIxGTJYDDE8KCE0MBwwNzI8Tw==QjIkESIxGTJYDDE8KCE0MBwwNzI8Tw==RTIkESIxGTJYDDE8KCE0MBwwNzI8Tw==RDIkESIxGTJYDDE8KCE0MBwwNzI8Tw== ``` ## Тестирование Вы можете проверять свой код из `main.go`. Чтобы скомпилировать и запустить программу с точкой входа в `main.go`, нажмите кнопку «Запустить». Когда весь конвейер будет готов к тестированию, нажмите кнопку «Отправить на проверку». По ней запустятся юнит-тесты из файла `main_test.go`. В этом же файле можно посмотреть ожидаемое поведение конвейера.