Ба чӣ гуна, ба назари шумо, самараноктарин усул дар кор бо стримҳо дар Java аст?

Эффективтарин усул барои кор бо потокҳо дар Java истифодаи потокҳои параллел дар якҷоягӣ бо оператсияҳои бебо мебошад.

Оператсияҳои бебо (монанди filter, map) танҳо вақте иҷро мешаванд, ки ин ҳатман зарур аст, ки миқдори маълумотҳои коркардшударо кам кунад.

Потокҳои параллел (parallel()) имкон медиҳанд, ки иҷрои оператсияҳоро дар чанд ядрои процессор параллелӣ кунанд, ки вақти коркарро барои миқдори калонтар маълумотҳо хеле кам мекунад.

Муҳим аст, ки хароҷоти иловагӣ дар истифодаи потокҳои параллел барои коллексияҳои хурд ба назар гирифта шавад. Ҳар ҳолат бояд самаранокии онро чен кунад.

Масалан барои истифодаи оператсияи бебо:

// Мо элементҳоро филтр мекунем, аммо ин танҳо вақте рӯй медиҳад, ки ба анҷоми оператсияи терминалӣ даъват кунем
// ё дар ҳоле ки дар поток итератсия мекунем. Ҳамон оператсия filter худкор кор намекунад.
stream.filter(element -> element > 10);

Масалан барои истифодаи потоки параллел:

// Коркарди элементҳо метавонад параллел карда шавад.
list.parallelStream().map(String::toUpperCase).collect(Collectors.toList());

Самаранокӣ инчунин аз интихоби оператсияи терминалӣ вобаста аст. collect(Collectors.toList()) ё forEach дар баъзе ҳолатҳо метавонанд самараноктар бошанд, аз reduce.

Ҳамагон, омехтаи оператсияҳои бебо ва потокҳои параллел, ки дар сценарияҳои мувофиқ истифода мешаванд, самаранокии максималро дар кор бо маҷмӯъҳои калонтар таъмин мекунанд.