Как реализована параллельная обработка данных в потоках Stream API на уровне внутренней реализации?