Если я ничего не путаю, стандартный System.Threading был основан на OmniThreadLibrary (OTL)
Так вот в OTL есть примитив Pipeline (конвейер)
Мне интересно, есть ли в стандартной библиотеке какой-либо аналог?

И ещё по конвейеру есть вопрос. Можно ли как-то настраивать приоритизацию потоков?
Например, у меня простенькая задача.
На первом шаге иерархично просматриваем директории, если файл удовлетворяет нашему требованию - кидаем его в output
На втором шаге обрабатываем найденный файл

Так вот есть у нас пул потоков. Нет смысла занимать эти потоки первой задачей, когда есть файлы на обработку.
Иначе первая задача может бесконечно раздуть output, пока вторая задача обрабатывается неспеша
Аналогично, если шагов в конвейере несколько - нет смысла тратить потоки на первые шаги, в то время как существуют необработанные шаги в конце конвейера.

Пара вопросов вдогонку:
- как, находясь в обработчике шага (TProc), выяснить, не находится ли конвейер в состоянии отмены (завершения)?
- правильно ли я понимаю, что первый шаг стартует в одном потоке?

Док,

Это вообще разные вещи :)

rgreat,

TQueue<T> не lock-free
А как ты распределишь количества и приоритеты потоков на одну задачу?
И как ты завершишь весь конвейер одним действием?

Я имел ввиду какое-то удобоваримое стандартное решение :)

asviridenkov,
Квейд,

В 2015 я проработал в Auslogic-е 5 дней :)
Мне даже оплатили это время :)

Гаджимурадов Рустам,

Не сработались. Им не понравилось качество моего кода.
Тимлид, например, не понял, почему я для текстового файла делаю сравнение S[i] <= #32, а не S[i] = ' '
Меня не устроило, что задача поставлена не конкретно

Гаджимурадов Рустам,

Да хз. Вроде Австралия

Давайте не про Delphi и не про Auslogics :)
Давайте про потоки и конвейер :)

YuRockSOFT FOR YOUДавайте не про Delphi и не про Auslogics :)
Давайте про потоки и конвейер :)
Так а что тут обсуждать? Примеры есть, дали тебе вроде. Я лично велосипед свой забацал бы

Я и забацал свой велосипед через свой класс потока. И создал количество потоков, равному числу ядер
Но у меня задача простая. И очереди, кстати, через спинлок, а не lock-free как в OTL. В любом случае OTL штука интересная и System.Threading тоже. Хочется знать, как цивилизованно решать подобные задачи. Ты же ни на один вопрос стартового топика не ответил. А спрашиваешь, что тут обсуждать )