algorithm_impl.h 170 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683
  1. // -*- C++ -*-
  2. //===-- algorithm_impl.h --------------------------------------------------===//
  3. //
  4. // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
  5. // See https://llvm.org/LICENSE.txt for license information.
  6. // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
  7. //
  8. //===----------------------------------------------------------------------===//
  9. #ifndef _PSTL_ALGORITHM_IMPL_H
  10. #define _PSTL_ALGORITHM_IMPL_H
  11. #include <iterator>
  12. #include <type_traits>
  13. #include <utility>
  14. #include <functional>
  15. #include <algorithm>
  16. #include "execution_impl.h"
  17. #include "memory_impl.h"
  18. #include "parallel_backend_utils.h"
  19. #include "parallel_backend.h"
  20. #include "parallel_impl.h"
  21. #include "unseq_backend_simd.h"
  22. namespace __pstl
  23. {
  24. namespace __internal
  25. {
  26. //------------------------------------------------------------------------
  27. // any_of
  28. //------------------------------------------------------------------------
  29. template <class _ForwardIterator, class _Pred>
  30. bool
  31. __brick_any_of(const _ForwardIterator __first, const _ForwardIterator __last, _Pred __pred,
  32. /*__is_vector=*/std::false_type) noexcept
  33. {
  34. return std::any_of(__first, __last, __pred);
  35. };
  36. template <class _ForwardIterator, class _Pred>
  37. bool
  38. __brick_any_of(const _ForwardIterator __first, const _ForwardIterator __last, _Pred __pred,
  39. /*__is_vector=*/std::true_type) noexcept
  40. {
  41. return __unseq_backend::__simd_or(__first, __last - __first, __pred);
  42. };
  43. template <class _ExecutionPolicy, class _ForwardIterator, class _Pred, class _IsVector>
  44. bool
  45. __pattern_any_of(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Pred __pred,
  46. _IsVector __is_vector, /*parallel=*/std::false_type) noexcept
  47. {
  48. return __internal::__brick_any_of(__first, __last, __pred, __is_vector);
  49. }
  50. template <class _ExecutionPolicy, class _ForwardIterator, class _Pred, class _IsVector>
  51. bool
  52. __pattern_any_of(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Pred __pred,
  53. _IsVector __is_vector, /*parallel=*/std::true_type)
  54. {
  55. return __internal::__except_handler([&]() {
  56. return __internal::__parallel_or(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  57. [__pred, __is_vector](_ForwardIterator __i, _ForwardIterator __j) {
  58. return __internal::__brick_any_of(__i, __j, __pred, __is_vector);
  59. });
  60. });
  61. }
  62. // [alg.foreach]
  63. // for_each_n with no policy
  64. template <class _ForwardIterator, class _Size, class _Function>
  65. _ForwardIterator
  66. __for_each_n_it_serial(_ForwardIterator __first, _Size __n, _Function __f)
  67. {
  68. for (; __n > 0; ++__first, --__n)
  69. __f(__first);
  70. return __first;
  71. }
  72. //------------------------------------------------------------------------
  73. // walk1 (pseudo)
  74. //
  75. // walk1 evaluates f(x) for each dereferenced value x drawn from [first,last)
  76. //------------------------------------------------------------------------
  77. template <class _ForwardIterator, class _Function>
  78. void
  79. __brick_walk1(_ForwardIterator __first, _ForwardIterator __last, _Function __f, /*vector=*/std::false_type) noexcept
  80. {
  81. std::for_each(__first, __last, __f);
  82. }
  83. template <class _RandomAccessIterator, class _Function>
  84. void
  85. __brick_walk1(_RandomAccessIterator __first, _RandomAccessIterator __last, _Function __f,
  86. /*vector=*/std::true_type) noexcept
  87. {
  88. __unseq_backend::__simd_walk_1(__first, __last - __first, __f);
  89. }
  90. template <class _ExecutionPolicy, class _ForwardIterator, class _Function, class _IsVector>
  91. void
  92. __pattern_walk1(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Function __f,
  93. _IsVector __is_vector,
  94. /*parallel=*/std::false_type) noexcept
  95. {
  96. __internal::__brick_walk1(__first, __last, __f, __is_vector);
  97. }
  98. template <class _ExecutionPolicy, class _ForwardIterator, class _Function, class _IsVector>
  99. void
  100. __pattern_walk1(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Function __f,
  101. _IsVector __is_vector,
  102. /*parallel=*/std::true_type)
  103. {
  104. __internal::__except_handler([&]() {
  105. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  106. [__f, __is_vector](_ForwardIterator __i, _ForwardIterator __j) {
  107. __internal::__brick_walk1(__i, __j, __f, __is_vector);
  108. });
  109. });
  110. }
  111. template <class _ExecutionPolicy, class _ForwardIterator, class _Brick>
  112. void
  113. __pattern_walk_brick(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Brick __brick,
  114. /*parallel=*/std::false_type) noexcept
  115. {
  116. __brick(__first, __last);
  117. }
  118. template <class _ExecutionPolicy, class _ForwardIterator, class _Brick>
  119. void
  120. __pattern_walk_brick(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Brick __brick,
  121. /*parallel=*/std::true_type)
  122. {
  123. __internal::__except_handler([&]() {
  124. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  125. [__brick](_ForwardIterator __i, _ForwardIterator __j) { __brick(__i, __j); });
  126. });
  127. }
  128. //------------------------------------------------------------------------
  129. // walk1_n
  130. //------------------------------------------------------------------------
  131. template <class _ForwardIterator, class _Size, class _Function>
  132. _ForwardIterator
  133. __brick_walk1_n(_ForwardIterator __first, _Size __n, _Function __f, /*_IsVectorTag=*/std::false_type)
  134. {
  135. return __internal::__for_each_n_it_serial(__first, __n,
  136. [&__f](_ForwardIterator __it) { __f(*__it); }); // calling serial version
  137. }
  138. template <class _RandomAccessIterator, class _DifferenceType, class _Function>
  139. _RandomAccessIterator
  140. __brick_walk1_n(_RandomAccessIterator __first, _DifferenceType __n, _Function __f,
  141. /*vectorTag=*/std::true_type) noexcept
  142. {
  143. return __unseq_backend::__simd_walk_1(__first, __n, __f);
  144. }
  145. template <class _ExecutionPolicy, class _ForwardIterator, class _Size, class _Function, class _IsVector>
  146. _ForwardIterator
  147. __pattern_walk1_n(_ExecutionPolicy&&, _ForwardIterator __first, _Size __n, _Function __f, _IsVector __is_vector,
  148. /*is_parallel=*/std::false_type) noexcept
  149. {
  150. return __internal::__brick_walk1_n(__first, __n, __f, __is_vector);
  151. }
  152. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Size, class _Function, class _IsVector>
  153. _RandomAccessIterator
  154. __pattern_walk1_n(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _Size __n, _Function __f,
  155. _IsVector __is_vector,
  156. /*is_parallel=*/std::true_type)
  157. {
  158. __internal::__pattern_walk1(std::forward<_ExecutionPolicy>(__exec), __first, __first + __n, __f, __is_vector,
  159. std::true_type());
  160. return __first + __n;
  161. }
  162. template <class _ExecutionPolicy, class _ForwardIterator, class _Size, class _Brick>
  163. _ForwardIterator
  164. __pattern_walk_brick_n(_ExecutionPolicy&&, _ForwardIterator __first, _Size __n, _Brick __brick,
  165. /*is_parallel=*/std::false_type) noexcept
  166. {
  167. return __brick(__first, __n);
  168. }
  169. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Size, class _Brick>
  170. _RandomAccessIterator
  171. __pattern_walk_brick_n(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _Size __n, _Brick __brick,
  172. /*is_parallel=*/std::true_type)
  173. {
  174. return __internal::__except_handler([&]() {
  175. __par_backend::__parallel_for(
  176. std::forward<_ExecutionPolicy>(__exec), __first, __first + __n,
  177. [__brick](_RandomAccessIterator __i, _RandomAccessIterator __j) { __brick(__i, __j - __i); });
  178. return __first + __n;
  179. });
  180. }
  181. //------------------------------------------------------------------------
  182. // walk2 (pseudo)
  183. //
  184. // walk2 evaluates f(x,y) for deferenced values (x,y) drawn from [first1,last1) and [first2,...)
  185. //------------------------------------------------------------------------
  186. template <class _ForwardIterator1, class _ForwardIterator2, class _Function>
  187. _ForwardIterator2
  188. __brick_walk2(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2, _Function __f,
  189. /*vector=*/std::false_type) noexcept
  190. {
  191. for (; __first1 != __last1; ++__first1, ++__first2)
  192. __f(*__first1, *__first2);
  193. return __first2;
  194. }
  195. template <class _ForwardIterator1, class _ForwardIterator2, class _Function>
  196. _ForwardIterator2
  197. __brick_walk2(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2, _Function __f,
  198. /*vector=*/std::true_type) noexcept
  199. {
  200. return __unseq_backend::__simd_walk_2(__first1, __last1 - __first1, __first2, __f);
  201. }
  202. template <class _ForwardIterator1, class _Size, class _ForwardIterator2, class _Function>
  203. _ForwardIterator2
  204. __brick_walk2_n(_ForwardIterator1 __first1, _Size __n, _ForwardIterator2 __first2, _Function __f,
  205. /*vector=*/std::false_type) noexcept
  206. {
  207. for (; __n > 0; --__n, ++__first1, ++__first2)
  208. __f(*__first1, *__first2);
  209. return __first2;
  210. }
  211. template <class _ForwardIterator1, class _Size, class _ForwardIterator2, class _Function>
  212. _ForwardIterator2
  213. __brick_walk2_n(_ForwardIterator1 __first1, _Size __n, _ForwardIterator2 __first2, _Function __f,
  214. /*vector=*/std::true_type) noexcept
  215. {
  216. return __unseq_backend::__simd_walk_2(__first1, __n, __first2, __f);
  217. }
  218. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Function, class _IsVector>
  219. _ForwardIterator2
  220. __pattern_walk2(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  221. _Function __f, _IsVector __is_vector, /*parallel=*/std::false_type) noexcept
  222. {
  223. return __internal::__brick_walk2(__first1, __last1, __first2, __f, __is_vector);
  224. }
  225. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Function, class _IsVector>
  226. _ForwardIterator2
  227. __pattern_walk2(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  228. _ForwardIterator2 __first2, _Function __f, _IsVector __is_vector, /*parallel=*/std::true_type)
  229. {
  230. return __internal::__except_handler([&]() {
  231. __par_backend::__parallel_for(
  232. std::forward<_ExecutionPolicy>(__exec), __first1, __last1,
  233. [__f, __first1, __first2, __is_vector](_ForwardIterator1 __i, _ForwardIterator1 __j) {
  234. __internal::__brick_walk2(__i, __j, __first2 + (__i - __first1), __f, __is_vector);
  235. });
  236. return __first2 + (__last1 - __first1);
  237. });
  238. }
  239. template <class _ExecutionPolicy, class _ForwardIterator1, class _Size, class _ForwardIterator2, class _Function,
  240. class _IsVector>
  241. _ForwardIterator2
  242. __pattern_walk2_n(_ExecutionPolicy&&, _ForwardIterator1 __first1, _Size __n, _ForwardIterator2 __first2, _Function __f,
  243. _IsVector __is_vector, /*parallel=*/std::false_type) noexcept
  244. {
  245. return __internal::__brick_walk2_n(__first1, __n, __first2, __f, __is_vector);
  246. }
  247. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _Size, class _RandomAccessIterator2,
  248. class _Function, class _IsVector>
  249. _RandomAccessIterator2
  250. __pattern_walk2_n(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _Size __n, _RandomAccessIterator2 __first2,
  251. _Function __f, _IsVector __is_vector, /*parallel=*/std::true_type)
  252. {
  253. return __internal::__pattern_walk2(std::forward<_ExecutionPolicy>(__exec), __first1, __first1 + __n, __first2, __f,
  254. __is_vector, std::true_type());
  255. }
  256. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Brick>
  257. _ForwardIterator2
  258. __pattern_walk2_brick(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  259. _ForwardIterator2 __first2, _Brick __brick, /*parallel=*/std::false_type) noexcept
  260. {
  261. return __brick(__first1, __last1, __first2);
  262. }
  263. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _RandomAccessIterator2, class _Brick>
  264. _RandomAccessIterator2
  265. __pattern_walk2_brick(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1,
  266. _RandomAccessIterator2 __first2, _Brick __brick, /*parallel=*/std::true_type)
  267. {
  268. return __internal::__except_handler([&]() {
  269. __par_backend::__parallel_for(
  270. std::forward<_ExecutionPolicy>(__exec), __first1, __last1,
  271. [__first1, __first2, __brick](_RandomAccessIterator1 __i, _RandomAccessIterator1 __j) {
  272. __brick(__i, __j, __first2 + (__i - __first1));
  273. });
  274. return __first2 + (__last1 - __first1);
  275. });
  276. }
  277. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _Size, class _RandomAccessIterator2, class _Brick>
  278. _RandomAccessIterator2
  279. __pattern_walk2_brick_n(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _Size __n,
  280. _RandomAccessIterator2 __first2, _Brick __brick, /*parallel=*/std::true_type)
  281. {
  282. return __internal::__except_handler([&]() {
  283. __par_backend::__parallel_for(
  284. std::forward<_ExecutionPolicy>(__exec), __first1, __first1 + __n,
  285. [__first1, __first2, __brick](_RandomAccessIterator1 __i, _RandomAccessIterator1 __j) {
  286. __brick(__i, __j - __i, __first2 + (__i - __first1));
  287. });
  288. return __first2 + __n;
  289. });
  290. }
  291. template <class _ExecutionPolicy, class _ForwardIterator1, class _Size, class _ForwardIterator2, class _Brick>
  292. _ForwardIterator2
  293. __pattern_walk2_brick_n(_ExecutionPolicy&&, _ForwardIterator1 __first1, _Size __n, _ForwardIterator2 __first2,
  294. _Brick __brick, /*parallel=*/std::false_type) noexcept
  295. {
  296. return __brick(__first1, __n, __first2);
  297. }
  298. //------------------------------------------------------------------------
  299. // walk3 (pseudo)
  300. //
  301. // walk3 evaluates f(x,y,z) for (x,y,z) drawn from [first1,last1), [first2,...), [first3,...)
  302. //------------------------------------------------------------------------
  303. template <class _ForwardIterator1, class _ForwardIterator2, class _ForwardIterator3, class _Function>
  304. _ForwardIterator3
  305. __brick_walk3(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  306. _ForwardIterator3 __first3, _Function __f, /*vector=*/std::false_type) noexcept
  307. {
  308. for (; __first1 != __last1; ++__first1, ++__first2, ++__first3)
  309. __f(*__first1, *__first2, *__first3);
  310. return __first3;
  311. }
  312. template <class _RandomAccessIterator1, class _RandomAccessIterator2, class _RandomAccessIterator3, class _Function>
  313. _RandomAccessIterator3
  314. __brick_walk3(_RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1, _RandomAccessIterator2 __first2,
  315. _RandomAccessIterator3 __first3, _Function __f, /*vector=*/std::true_type) noexcept
  316. {
  317. return __unseq_backend::__simd_walk_3(__first1, __last1 - __first1, __first2, __first3, __f);
  318. }
  319. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _ForwardIterator3,
  320. class _Function, class _IsVector>
  321. _ForwardIterator3
  322. __pattern_walk3(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  323. _ForwardIterator3 __first3, _Function __f, _IsVector __is_vector, /*parallel=*/std::false_type) noexcept
  324. {
  325. return __internal::__brick_walk3(__first1, __last1, __first2, __first3, __f, __is_vector);
  326. }
  327. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _RandomAccessIterator2,
  328. class _RandomAccessIterator3, class _Function, class _IsVector>
  329. _RandomAccessIterator3
  330. __pattern_walk3(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1,
  331. _RandomAccessIterator2 __first2, _RandomAccessIterator3 __first3, _Function __f, _IsVector __is_vector,
  332. /*parallel=*/std::true_type)
  333. {
  334. return __internal::__except_handler([&]() {
  335. __par_backend::__parallel_for(
  336. std::forward<_ExecutionPolicy>(__exec), __first1, __last1,
  337. [__f, __first1, __first2, __first3, __is_vector](_RandomAccessIterator1 __i, _RandomAccessIterator1 __j) {
  338. __internal::__brick_walk3(__i, __j, __first2 + (__i - __first1), __first3 + (__i - __first1), __f,
  339. __is_vector);
  340. });
  341. return __first3 + (__last1 - __first1);
  342. });
  343. }
  344. //------------------------------------------------------------------------
  345. // equal
  346. //------------------------------------------------------------------------
  347. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  348. bool
  349. __brick_equal(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  350. _ForwardIterator2 __last2, _BinaryPredicate __p, /* IsVector = */ std::false_type) noexcept
  351. {
  352. return std::equal(__first1, __last1, __first2, __last2, __p);
  353. }
  354. template <class _RandomAccessIterator1, class _RandomAccessIterator2, class _BinaryPredicate>
  355. bool
  356. __brick_equal(_RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1, _RandomAccessIterator2 __first2,
  357. _RandomAccessIterator2 __last2, _BinaryPredicate __p, /* is_vector = */ std::true_type) noexcept
  358. {
  359. if (__last1 - __first1 != __last2 - __first2)
  360. return false;
  361. return __unseq_backend::__simd_first(__first1, __last1 - __first1, __first2, std::not_fn(__p)).first == __last1;
  362. }
  363. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  364. class _IsVector>
  365. bool
  366. __pattern_equal(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  367. _ForwardIterator2 __last2, _BinaryPredicate __p, _IsVector __is_vector, /* is_parallel = */
  368. std::false_type) noexcept
  369. {
  370. return __internal::__brick_equal(__first1, __last1, __first2, __last2, __p, __is_vector);
  371. }
  372. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _RandomAccessIterator2, class _BinaryPredicate,
  373. class _IsVector>
  374. bool
  375. __pattern_equal(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1,
  376. _RandomAccessIterator2 __first2, _RandomAccessIterator2 __last2, _BinaryPredicate __p,
  377. _IsVector __is_vector, /*is_parallel=*/std::true_type)
  378. {
  379. if (__last1 - __first1 != __last2 - __first2)
  380. return false;
  381. return __internal::__except_handler([&]() {
  382. return !__internal::__parallel_or(
  383. std::forward<_ExecutionPolicy>(__exec), __first1, __last1,
  384. [__first1, __first2, __p, __is_vector](_RandomAccessIterator1 __i, _RandomAccessIterator1 __j) {
  385. return !__internal::__brick_equal(__i, __j, __first2 + (__i - __first1), __first2 + (__j - __first1),
  386. __p, __is_vector);
  387. });
  388. });
  389. }
  390. //------------------------------------------------------------------------
  391. // equal version for sequences with equal length
  392. //------------------------------------------------------------------------
  393. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  394. bool
  395. __brick_equal(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2, _BinaryPredicate __p,
  396. /* IsVector = */ std::false_type) noexcept
  397. {
  398. return std::equal(__first1, __last1, __first2, __p);
  399. }
  400. template <class _RandomAccessIterator1, class _RandomAccessIterator2, class _BinaryPredicate>
  401. bool
  402. __brick_equal(_RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1, _RandomAccessIterator2 __first2,
  403. _BinaryPredicate __p, /* is_vector = */ std::true_type) noexcept
  404. {
  405. return __unseq_backend::__simd_first(__first1, __last1 - __first1, __first2, std::not_fn(__p)).first == __last1;
  406. }
  407. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  408. class _IsVector>
  409. bool
  410. __pattern_equal(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  411. _BinaryPredicate __p, _IsVector __is_vector, /* is_parallel = */ std::false_type) noexcept
  412. {
  413. return __internal::__brick_equal(__first1, __last1, __first2, __p, __is_vector);
  414. }
  415. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _RandomAccessIterator2, class _BinaryPredicate,
  416. class _IsVector>
  417. bool
  418. __pattern_equal(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1,
  419. _RandomAccessIterator2 __first2, _BinaryPredicate __p, _IsVector __is_vector,
  420. /*is_parallel=*/std::true_type)
  421. {
  422. return __internal::__except_handler([&]() {
  423. return !__internal::__parallel_or(
  424. std::forward<_ExecutionPolicy>(__exec), __first1, __last1,
  425. [__first1, __first2, __p, __is_vector](_RandomAccessIterator1 __i, _RandomAccessIterator1 __j) {
  426. return !__internal::__brick_equal(__i, __j, __first2 + (__i - __first1), __p, __is_vector);
  427. });
  428. });
  429. }
  430. //------------------------------------------------------------------------
  431. // find_if
  432. //------------------------------------------------------------------------
  433. template <class _ForwardIterator, class _Predicate>
  434. _ForwardIterator
  435. __brick_find_if(_ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  436. /*is_vector=*/std::false_type) noexcept
  437. {
  438. return std::find_if(__first, __last, __pred);
  439. }
  440. template <class _RandomAccessIterator, class _Predicate>
  441. _RandomAccessIterator
  442. __brick_find_if(_RandomAccessIterator __first, _RandomAccessIterator __last, _Predicate __pred,
  443. /*is_vector=*/std::true_type) noexcept
  444. {
  445. typedef typename std::iterator_traits<_RandomAccessIterator>::difference_type _SizeType;
  446. return __unseq_backend::__simd_first(
  447. __first, _SizeType(0), __last - __first,
  448. [&__pred](_RandomAccessIterator __it, _SizeType __i) { return __pred(__it[__i]); });
  449. }
  450. template <class _ExecutionPolicy, class _ForwardIterator, class _Predicate, class _IsVector>
  451. _ForwardIterator
  452. __pattern_find_if(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  453. _IsVector __is_vector,
  454. /*is_parallel=*/std::false_type) noexcept
  455. {
  456. return __internal::__brick_find_if(__first, __last, __pred, __is_vector);
  457. }
  458. template <class _ExecutionPolicy, class _ForwardIterator, class _Predicate, class _IsVector>
  459. _ForwardIterator
  460. __pattern_find_if(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  461. _IsVector __is_vector,
  462. /*is_parallel=*/std::true_type)
  463. {
  464. return __internal::__except_handler([&]() {
  465. return __internal::__parallel_find(
  466. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  467. [__pred, __is_vector](_ForwardIterator __i, _ForwardIterator __j) {
  468. return __internal::__brick_find_if(__i, __j, __pred, __is_vector);
  469. },
  470. std::less<typename std::iterator_traits<_ForwardIterator>::difference_type>(),
  471. /*is_first=*/true);
  472. });
  473. }
  474. //------------------------------------------------------------------------
  475. // find_end
  476. //------------------------------------------------------------------------
  477. // find the first occurrence of the subsequence [s_first, s_last)
  478. // or the last occurrence of the subsequence in the range [first, last)
  479. // b_first determines what occurrence we want to find (first or last)
  480. template <class _RandomAccessIterator1, class _RandomAccessIterator2, class _BinaryPredicate, class _IsVector>
  481. _RandomAccessIterator1
  482. __find_subrange(_RandomAccessIterator1 __first, _RandomAccessIterator1 __last, _RandomAccessIterator1 __global_last,
  483. _RandomAccessIterator2 __s_first, _RandomAccessIterator2 __s_last, _BinaryPredicate __pred,
  484. bool __b_first, _IsVector __is_vector) noexcept
  485. {
  486. typedef typename std::iterator_traits<_RandomAccessIterator2>::value_type _ValueType;
  487. auto __n2 = __s_last - __s_first;
  488. if (__n2 < 1)
  489. {
  490. return __b_first ? __first : __last;
  491. }
  492. auto __n1 = __global_last - __first;
  493. if (__n1 < __n2)
  494. {
  495. return __last;
  496. }
  497. auto __cur = __last;
  498. while (__first != __last && (__global_last - __first >= __n2))
  499. {
  500. // find position of *s_first in [first, last) (it can be start of subsequence)
  501. __first = __internal::__brick_find_if(
  502. __first, __last, __equal_value_by_pred<_ValueType, _BinaryPredicate>(*__s_first, __pred), __is_vector);
  503. // if position that was found previously is the start of subsequence
  504. // then we can exit the loop (b_first == true) or keep the position
  505. // (b_first == false)
  506. if (__first != __last && (__global_last - __first >= __n2) &&
  507. __internal::__brick_equal(__s_first + 1, __s_last, __first + 1, __pred, __is_vector))
  508. {
  509. if (__b_first)
  510. {
  511. return __first;
  512. }
  513. else
  514. {
  515. __cur = __first;
  516. }
  517. }
  518. else if (__first == __last)
  519. {
  520. break;
  521. }
  522. else
  523. {
  524. }
  525. // in case of b_first == false we try to find new start position
  526. // for the next subsequence
  527. ++__first;
  528. }
  529. return __cur;
  530. }
  531. template <class _RandomAccessIterator, class _Size, class _Tp, class _BinaryPredicate, class _IsVector>
  532. _RandomAccessIterator
  533. __find_subrange(_RandomAccessIterator __first, _RandomAccessIterator __last, _RandomAccessIterator __global_last,
  534. _Size __count, const _Tp& __value, _BinaryPredicate __pred, _IsVector __is_vector) noexcept
  535. {
  536. if (static_cast<_Size>(__global_last - __first) < __count || __count < 1)
  537. {
  538. return __last; // According to the standard last shall be returned when count < 1
  539. }
  540. auto __unary_pred = __equal_value_by_pred<_Tp, _BinaryPredicate>(__value, __pred);
  541. while (__first != __last && (static_cast<_Size>(__global_last - __first) >= __count))
  542. {
  543. __first = __internal::__brick_find_if(__first, __last, __unary_pred, __is_vector);
  544. // check that all of elements in [first+1, first+count) equal to value
  545. if (__first != __last && (static_cast<_Size>(__global_last - __first) >= __count) &&
  546. !__internal::__brick_any_of(__first + 1, __first + __count, std::not_fn(__unary_pred), __is_vector))
  547. {
  548. return __first;
  549. }
  550. else if (__first == __last)
  551. {
  552. break;
  553. }
  554. else
  555. {
  556. ++__first;
  557. }
  558. }
  559. return __last;
  560. }
  561. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  562. _ForwardIterator1
  563. __brick_find_end(_ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  564. _ForwardIterator2 __s_last, _BinaryPredicate __pred, /*__is_vector=*/std::false_type) noexcept
  565. {
  566. return std::find_end(__first, __last, __s_first, __s_last, __pred);
  567. }
  568. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  569. _ForwardIterator1
  570. __brick_find_end(_ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  571. _ForwardIterator2 __s_last, _BinaryPredicate __pred, /*__is_vector=*/std::true_type) noexcept
  572. {
  573. return __find_subrange(__first, __last, __last, __s_first, __s_last, __pred, false, std::true_type());
  574. }
  575. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  576. class _IsVector>
  577. _ForwardIterator1
  578. __pattern_find_end(_ExecutionPolicy&&, _ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  579. _ForwardIterator2 __s_last, _BinaryPredicate __pred, _IsVector __is_vector,
  580. /*is_parallel=*/std::false_type) noexcept
  581. {
  582. return __internal::__brick_find_end(__first, __last, __s_first, __s_last, __pred, __is_vector);
  583. }
  584. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  585. class _IsVector>
  586. _ForwardIterator1
  587. __pattern_find_end(_ExecutionPolicy&& __exec, _ForwardIterator1 __first, _ForwardIterator1 __last,
  588. _ForwardIterator2 __s_first, _ForwardIterator2 __s_last, _BinaryPredicate __pred,
  589. _IsVector __is_vector, /*is_parallel=*/std::true_type) noexcept
  590. {
  591. if (__last - __first == __s_last - __s_first)
  592. {
  593. const bool __res = __internal::__pattern_equal(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  594. __s_first, __pred, __is_vector, std::true_type());
  595. return __res ? __first : __last;
  596. }
  597. else
  598. {
  599. return __internal::__except_handler([&]() {
  600. return __internal::__parallel_find(
  601. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  602. [__last, __s_first, __s_last, __pred, __is_vector](_ForwardIterator1 __i, _ForwardIterator1 __j) {
  603. return __internal::__find_subrange(__i, __j, __last, __s_first, __s_last, __pred, false,
  604. __is_vector);
  605. },
  606. std::greater<typename std::iterator_traits<_ForwardIterator1>::difference_type>(), /*is_first=*/false);
  607. });
  608. }
  609. }
  610. //------------------------------------------------------------------------
  611. // find_first_of
  612. //------------------------------------------------------------------------
  613. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  614. _ForwardIterator1
  615. __brick_find_first_of(_ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  616. _ForwardIterator2 __s_last, _BinaryPredicate __pred, /*__is_vector=*/std::false_type) noexcept
  617. {
  618. return std::find_first_of(__first, __last, __s_first, __s_last, __pred);
  619. }
  620. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  621. _ForwardIterator1
  622. __brick_find_first_of(_ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  623. _ForwardIterator2 __s_last, _BinaryPredicate __pred, /*__is_vector=*/std::true_type) noexcept
  624. {
  625. return __unseq_backend::__simd_find_first_of(__first, __last, __s_first, __s_last, __pred);
  626. }
  627. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  628. class _IsVector>
  629. _ForwardIterator1
  630. __pattern_find_first_of(_ExecutionPolicy&&, _ForwardIterator1 __first, _ForwardIterator1 __last,
  631. _ForwardIterator2 __s_first, _ForwardIterator2 __s_last, _BinaryPredicate __pred,
  632. _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  633. {
  634. return __internal::__brick_find_first_of(__first, __last, __s_first, __s_last, __pred, __is_vector);
  635. }
  636. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  637. class _IsVector>
  638. _ForwardIterator1
  639. __pattern_find_first_of(_ExecutionPolicy&& __exec, _ForwardIterator1 __first, _ForwardIterator1 __last,
  640. _ForwardIterator2 __s_first, _ForwardIterator2 __s_last, _BinaryPredicate __pred,
  641. _IsVector __is_vector, /*is_parallel=*/std::true_type) noexcept
  642. {
  643. return __internal::__except_handler([&]() {
  644. return __internal::__parallel_find(
  645. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  646. [__s_first, __s_last, __pred, __is_vector](_ForwardIterator1 __i, _ForwardIterator1 __j) {
  647. return __internal::__brick_find_first_of(__i, __j, __s_first, __s_last, __pred, __is_vector);
  648. },
  649. std::less<typename std::iterator_traits<_ForwardIterator1>::difference_type>(), /*is_first=*/true);
  650. });
  651. }
  652. //------------------------------------------------------------------------
  653. // search
  654. //------------------------------------------------------------------------
  655. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  656. _ForwardIterator1
  657. __brick_search(_ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  658. _ForwardIterator2 __s_last, _BinaryPredicate __pred, /*vector=*/std::false_type) noexcept
  659. {
  660. return std::search(__first, __last, __s_first, __s_last, __pred);
  661. }
  662. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  663. _ForwardIterator1
  664. __brick_search(_ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  665. _ForwardIterator2 __s_last, _BinaryPredicate __pred, /*vector=*/std::true_type) noexcept
  666. {
  667. return __internal::__find_subrange(__first, __last, __last, __s_first, __s_last, __pred, true, std::true_type());
  668. }
  669. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  670. class _IsVector>
  671. _ForwardIterator1
  672. __pattern_search(_ExecutionPolicy&&, _ForwardIterator1 __first, _ForwardIterator1 __last, _ForwardIterator2 __s_first,
  673. _ForwardIterator2 __s_last, _BinaryPredicate __pred, _IsVector __is_vector,
  674. /*is_parallel=*/std::false_type) noexcept
  675. {
  676. return __internal::__brick_search(__first, __last, __s_first, __s_last, __pred, __is_vector);
  677. }
  678. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate,
  679. class _IsVector>
  680. _ForwardIterator1
  681. __pattern_search(_ExecutionPolicy&& __exec, _ForwardIterator1 __first, _ForwardIterator1 __last,
  682. _ForwardIterator2 __s_first, _ForwardIterator2 __s_last, _BinaryPredicate __pred,
  683. _IsVector __is_vector,
  684. /*is_parallel=*/std::true_type) noexcept
  685. {
  686. if (__last - __first == __s_last - __s_first)
  687. {
  688. const bool __res = __internal::__pattern_equal(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  689. __s_first, __pred, __is_vector, std::true_type());
  690. return __res ? __first : __last;
  691. }
  692. else
  693. {
  694. return __internal::__except_handler([&]() {
  695. return __internal::__parallel_find(
  696. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  697. [__last, __s_first, __s_last, __pred, __is_vector](_ForwardIterator1 __i, _ForwardIterator1 __j) {
  698. return __internal::__find_subrange(__i, __j, __last, __s_first, __s_last, __pred, true,
  699. __is_vector);
  700. },
  701. std::less<typename std::iterator_traits<_ForwardIterator1>::difference_type>(), /*is_first=*/true);
  702. });
  703. }
  704. }
  705. //------------------------------------------------------------------------
  706. // search_n
  707. //------------------------------------------------------------------------
  708. template <class _ForwardIterator, class _Size, class _Tp, class _BinaryPredicate>
  709. _ForwardIterator
  710. __brick_search_n(_ForwardIterator __first, _ForwardIterator __last, _Size __count, const _Tp& __value,
  711. _BinaryPredicate __pred, /*vector=*/std::false_type) noexcept
  712. {
  713. return std::search_n(__first, __last, __count, __value, __pred);
  714. }
  715. template <class _ForwardIterator, class _Size, class _Tp, class _BinaryPredicate>
  716. _ForwardIterator
  717. __brick_search_n(_ForwardIterator __first, _ForwardIterator __last, _Size __count, const _Tp& __value,
  718. _BinaryPredicate __pred, /*vector=*/std::true_type) noexcept
  719. {
  720. return __internal::__find_subrange(__first, __last, __last, __count, __value, __pred, std::true_type());
  721. }
  722. template <class _ExecutionPolicy, class _ForwardIterator, class _Size, class _Tp, class _BinaryPredicate,
  723. class _IsVector>
  724. _ForwardIterator
  725. __pattern_search_n(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Size __count,
  726. const _Tp& __value, _BinaryPredicate __pred, _IsVector __is_vector,
  727. /*is_parallel=*/std::false_type) noexcept
  728. {
  729. return __internal::__brick_search_n(__first, __last, __count, __value, __pred, __is_vector);
  730. }
  731. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Size, class _Tp, class _BinaryPredicate,
  732. class _IsVector>
  733. _RandomAccessIterator
  734. __pattern_search_n(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  735. _Size __count, const _Tp& __value, _BinaryPredicate __pred, _IsVector __is_vector,
  736. /*is_parallel=*/std::true_type) noexcept
  737. {
  738. if (static_cast<_Size>(__last - __first) == __count)
  739. {
  740. const bool __result = !__internal::__pattern_any_of(
  741. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  742. [&__value, &__pred](const _Tp& __val) { return !__pred(__val, __value); }, __is_vector,
  743. /*is_parallel*/ std::true_type());
  744. return __result ? __first : __last;
  745. }
  746. else
  747. {
  748. return __internal::__except_handler([&__exec, __first, __last, __count, &__value, __pred, __is_vector]() {
  749. return __internal::__parallel_find(
  750. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  751. [__last, __count, &__value, __pred, __is_vector](_RandomAccessIterator __i, _RandomAccessIterator __j) {
  752. return __internal::__find_subrange(__i, __j, __last, __count, __value, __pred, __is_vector);
  753. },
  754. std::less<typename std::iterator_traits<_RandomAccessIterator>::difference_type>(), /*is_first=*/true);
  755. });
  756. }
  757. }
  758. //------------------------------------------------------------------------
  759. // copy_n
  760. //------------------------------------------------------------------------
  761. template <class _ForwardIterator, class _Size, class _OutputIterator>
  762. _OutputIterator
  763. __brick_copy_n(_ForwardIterator __first, _Size __n, _OutputIterator __result, /*vector=*/std::false_type) noexcept
  764. {
  765. return std::copy_n(__first, __n, __result);
  766. }
  767. template <class _ForwardIterator, class _Size, class _OutputIterator>
  768. _OutputIterator
  769. __brick_copy_n(_ForwardIterator __first, _Size __n, _OutputIterator __result, /*vector=*/std::true_type) noexcept
  770. {
  771. return __unseq_backend::__simd_assign(
  772. __first, __n, __result, [](_ForwardIterator __first, _OutputIterator __result) { *__result = *__first; });
  773. }
  774. //------------------------------------------------------------------------
  775. // copy
  776. //------------------------------------------------------------------------
  777. template <class _ForwardIterator, class _OutputIterator>
  778. _OutputIterator
  779. __brick_copy(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  780. /*vector=*/std::false_type) noexcept
  781. {
  782. return std::copy(__first, __last, __result);
  783. }
  784. template <class _RandomAccessIterator, class _OutputIterator>
  785. _OutputIterator
  786. __brick_copy(_RandomAccessIterator __first, _RandomAccessIterator __last, _OutputIterator __result,
  787. /*vector=*/std::true_type) noexcept
  788. {
  789. return __unseq_backend::__simd_assign(
  790. __first, __last - __first, __result,
  791. [](_RandomAccessIterator __first, _OutputIterator __result) { *__result = *__first; });
  792. }
  793. //------------------------------------------------------------------------
  794. // move
  795. //------------------------------------------------------------------------
  796. template <class _ForwardIterator, class _OutputIterator>
  797. _OutputIterator
  798. __brick_move(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  799. /*vector=*/std::false_type) noexcept
  800. {
  801. return std::move(__first, __last, __result);
  802. }
  803. template <class _RandomAccessIterator, class _OutputIterator>
  804. _OutputIterator
  805. __brick_move(_RandomAccessIterator __first, _RandomAccessIterator __last, _OutputIterator __result,
  806. /*vector=*/std::true_type) noexcept
  807. {
  808. return __unseq_backend::__simd_assign(
  809. __first, __last - __first, __result,
  810. [](_RandomAccessIterator __first, _OutputIterator __result) { *__result = std::move(*__first); });
  811. }
  812. struct __brick_move_destroy
  813. {
  814. template <typename _Iterator, typename _OutputIterator>
  815. _OutputIterator
  816. operator()(_Iterator __first, _Iterator __last, _OutputIterator __result, /*vec*/ std::true_type) const
  817. {
  818. using _IteratorValueType = typename std::iterator_traits<_Iterator>::value_type;
  819. return __unseq_backend::__simd_assign(__first, __last - __first, __result,
  820. [](_Iterator __first, _OutputIterator __result) {
  821. *__result = std::move(*__first);
  822. (*__first).~_IteratorValueType();
  823. });
  824. }
  825. template <typename _Iterator, typename _OutputIterator>
  826. _OutputIterator
  827. operator()(_Iterator __first, _Iterator __last, _OutputIterator __result, /*vec*/ std::false_type) const
  828. {
  829. using _IteratorValueType = typename std::iterator_traits<_Iterator>::value_type;
  830. for (; __first != __last; ++__first, ++__result)
  831. {
  832. *__result = std::move(*__first);
  833. (*__first).~_IteratorValueType();
  834. }
  835. return __result;
  836. }
  837. };
  838. //------------------------------------------------------------------------
  839. // swap_ranges
  840. //------------------------------------------------------------------------
  841. template <class _ForwardIterator, class _OutputIterator>
  842. _OutputIterator
  843. __brick_swap_ranges(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  844. /*vector=*/std::false_type) noexcept
  845. {
  846. return std::swap_ranges(__first, __last, __result);
  847. }
  848. template <class _ForwardIterator, class _OutputIterator>
  849. _OutputIterator
  850. __brick_swap_ranges(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  851. /*vector=*/std::true_type) noexcept
  852. {
  853. using std::iter_swap;
  854. return __unseq_backend::__simd_assign(__first, __last - __first, __result,
  855. iter_swap<_ForwardIterator, _OutputIterator>);
  856. }
  857. //------------------------------------------------------------------------
  858. // copy_if
  859. //------------------------------------------------------------------------
  860. template <class _ForwardIterator, class _OutputIterator, class _UnaryPredicate>
  861. _OutputIterator
  862. __brick_copy_if(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result, _UnaryPredicate __pred,
  863. /*vector=*/std::false_type) noexcept
  864. {
  865. return std::copy_if(__first, __last, __result, __pred);
  866. }
  867. template <class _ForwardIterator, class _OutputIterator, class _UnaryPredicate>
  868. _OutputIterator
  869. __brick_copy_if(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result, _UnaryPredicate __pred,
  870. /*vector=*/std::true_type) noexcept
  871. {
  872. #if (_PSTL_MONOTONIC_PRESENT)
  873. return __unseq_backend::__simd_copy_if(__first, __last - __first, __result, __pred);
  874. #else
  875. return std::copy_if(__first, __last, __result, __pred);
  876. #endif
  877. }
  878. // TODO: Try to use transform_reduce for combining __brick_copy_if_phase1 on IsVector.
  879. template <class _DifferenceType, class _ForwardIterator, class _UnaryPredicate>
  880. std::pair<_DifferenceType, _DifferenceType>
  881. __brick_calc_mask_1(_ForwardIterator __first, _ForwardIterator __last, bool* __restrict __mask, _UnaryPredicate __pred,
  882. /*vector=*/std::false_type) noexcept
  883. {
  884. auto __count_true = _DifferenceType(0);
  885. auto __size = __last - __first;
  886. static_assert(__is_random_access_iterator<_ForwardIterator>::value,
  887. "Pattern-brick error. Should be a random access iterator.");
  888. for (; __first != __last; ++__first, ++__mask)
  889. {
  890. *__mask = __pred(*__first);
  891. if (*__mask)
  892. {
  893. ++__count_true;
  894. }
  895. }
  896. return std::make_pair(__count_true, __size - __count_true);
  897. }
  898. template <class _DifferenceType, class _RandomAccessIterator, class _UnaryPredicate>
  899. std::pair<_DifferenceType, _DifferenceType>
  900. __brick_calc_mask_1(_RandomAccessIterator __first, _RandomAccessIterator __last, bool* __mask, _UnaryPredicate __pred,
  901. /*vector=*/std::true_type) noexcept
  902. {
  903. auto __result = __unseq_backend::__simd_calc_mask_1(__first, __last - __first, __mask, __pred);
  904. return std::make_pair(__result, (__last - __first) - __result);
  905. }
  906. template <class _ForwardIterator, class _OutputIterator, class _Assigner>
  907. void
  908. __brick_copy_by_mask(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result, bool* __mask,
  909. _Assigner __assigner, /*vector=*/std::false_type) noexcept
  910. {
  911. for (; __first != __last; ++__first, ++__mask)
  912. {
  913. if (*__mask)
  914. {
  915. __assigner(__first, __result);
  916. ++__result;
  917. }
  918. }
  919. }
  920. template <class _ForwardIterator, class _OutputIterator, class _Assigner>
  921. void
  922. __brick_copy_by_mask(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  923. bool* __restrict __mask, _Assigner __assigner, /*vector=*/std::true_type) noexcept
  924. {
  925. #if (_PSTL_MONOTONIC_PRESENT)
  926. __unseq_backend::__simd_copy_by_mask(__first, __last - __first, __result, __mask, __assigner);
  927. #else
  928. __internal::__brick_copy_by_mask(__first, __last, __result, __mask, __assigner, std::false_type());
  929. #endif
  930. }
  931. template <class _ForwardIterator, class _OutputIterator1, class _OutputIterator2>
  932. void
  933. __brick_partition_by_mask(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator1 __out_true,
  934. _OutputIterator2 __out_false, bool* __mask, /*vector=*/std::false_type) noexcept
  935. {
  936. for (; __first != __last; ++__first, ++__mask)
  937. {
  938. if (*__mask)
  939. {
  940. *__out_true = *__first;
  941. ++__out_true;
  942. }
  943. else
  944. {
  945. *__out_false = *__first;
  946. ++__out_false;
  947. }
  948. }
  949. }
  950. template <class _RandomAccessIterator, class _OutputIterator1, class _OutputIterator2>
  951. void
  952. __brick_partition_by_mask(_RandomAccessIterator __first, _RandomAccessIterator __last, _OutputIterator1 __out_true,
  953. _OutputIterator2 __out_false, bool* __mask, /*vector=*/std::true_type) noexcept
  954. {
  955. #if (_PSTL_MONOTONIC_PRESENT)
  956. __unseq_backend::__simd_partition_by_mask(__first, __last - __first, __out_true, __out_false, __mask);
  957. #else
  958. __internal::__brick_partition_by_mask(__first, __last, __out_true, __out_false, __mask, std::false_type());
  959. #endif
  960. }
  961. template <class _ExecutionPolicy, class _ForwardIterator, class _OutputIterator, class _UnaryPredicate, class _IsVector>
  962. _OutputIterator
  963. __pattern_copy_if(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  964. _UnaryPredicate __pred, _IsVector __is_vector, /*parallel=*/std::false_type) noexcept
  965. {
  966. return __internal::__brick_copy_if(__first, __last, __result, __pred, __is_vector);
  967. }
  968. template <class _ExecutionPolicy, class _RandomAccessIterator, class _OutputIterator, class _UnaryPredicate,
  969. class _IsVector>
  970. _OutputIterator
  971. __pattern_copy_if(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  972. _OutputIterator __result, _UnaryPredicate __pred, _IsVector __is_vector, /*parallel=*/std::true_type)
  973. {
  974. typedef typename std::iterator_traits<_RandomAccessIterator>::difference_type _DifferenceType;
  975. const _DifferenceType __n = __last - __first;
  976. if (_DifferenceType(1) < __n)
  977. {
  978. __par_backend::__buffer<bool> __mask_buf(__n);
  979. return __internal::__except_handler([&__exec, __n, __first, __result, __is_vector, __pred, &__mask_buf]() {
  980. bool* __mask = __mask_buf.get();
  981. _DifferenceType __m{};
  982. __par_backend::__parallel_strict_scan(
  983. std::forward<_ExecutionPolicy>(__exec), __n, _DifferenceType(0),
  984. [=](_DifferenceType __i, _DifferenceType __len) { // Reduce
  985. return __internal::__brick_calc_mask_1<_DifferenceType>(__first + __i, __first + (__i + __len),
  986. __mask + __i, __pred, __is_vector)
  987. .first;
  988. },
  989. std::plus<_DifferenceType>(), // Combine
  990. [=](_DifferenceType __i, _DifferenceType __len, _DifferenceType __initial) { // Scan
  991. __internal::__brick_copy_by_mask(
  992. __first + __i, __first + (__i + __len), __result + __initial, __mask + __i,
  993. [](_RandomAccessIterator __x, _OutputIterator __z) { *__z = *__x; }, __is_vector);
  994. },
  995. [&__m](_DifferenceType __total) { __m = __total; });
  996. return __result + __m;
  997. });
  998. }
  999. // trivial sequence - use serial algorithm
  1000. return __internal::__brick_copy_if(__first, __last, __result, __pred, __is_vector);
  1001. }
  1002. //------------------------------------------------------------------------
  1003. // count
  1004. //------------------------------------------------------------------------
  1005. template <class _ForwardIterator, class _Predicate>
  1006. typename std::iterator_traits<_ForwardIterator>::difference_type
  1007. __brick_count(_ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  1008. /* is_vector = */ std::true_type) noexcept
  1009. {
  1010. return __unseq_backend::__simd_count(__first, __last - __first, __pred);
  1011. }
  1012. template <class _ForwardIterator, class _Predicate>
  1013. typename std::iterator_traits<_ForwardIterator>::difference_type
  1014. __brick_count(_ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  1015. /* is_vector = */ std::false_type) noexcept
  1016. {
  1017. return std::count_if(__first, __last, __pred);
  1018. }
  1019. template <class _ExecutionPolicy, class _ForwardIterator, class _Predicate, class _IsVector>
  1020. typename std::iterator_traits<_ForwardIterator>::difference_type
  1021. __pattern_count(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  1022. /* is_parallel */ std::false_type, _IsVector __is_vector) noexcept
  1023. {
  1024. return __internal::__brick_count(__first, __last, __pred, __is_vector);
  1025. }
  1026. template <class _ExecutionPolicy, class _ForwardIterator, class _Predicate, class _IsVector>
  1027. typename std::iterator_traits<_ForwardIterator>::difference_type
  1028. __pattern_count(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Predicate __pred,
  1029. /* is_parallel */ std::true_type, _IsVector __is_vector)
  1030. {
  1031. typedef typename std::iterator_traits<_ForwardIterator>::difference_type _SizeType;
  1032. return __internal::__except_handler([&]() {
  1033. return __par_backend::__parallel_reduce(
  1034. std::forward<_ExecutionPolicy>(__exec), __first, __last, _SizeType(0),
  1035. [__pred, __is_vector](_ForwardIterator __begin, _ForwardIterator __end, _SizeType __value) -> _SizeType {
  1036. return __value + __internal::__brick_count(__begin, __end, __pred, __is_vector);
  1037. },
  1038. std::plus<_SizeType>());
  1039. });
  1040. }
  1041. //------------------------------------------------------------------------
  1042. // unique
  1043. //------------------------------------------------------------------------
  1044. template <class _ForwardIterator, class _BinaryPredicate>
  1045. _ForwardIterator
  1046. __brick_unique(_ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  1047. /*is_vector=*/std::false_type) noexcept
  1048. {
  1049. return std::unique(__first, __last, __pred);
  1050. }
  1051. template <class _ForwardIterator, class _BinaryPredicate>
  1052. _ForwardIterator
  1053. __brick_unique(_ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  1054. /*is_vector=*/std::true_type) noexcept
  1055. {
  1056. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  1057. return std::unique(__first, __last, __pred);
  1058. }
  1059. template <class _ExecutionPolicy, class _ForwardIterator, class _BinaryPredicate, class _IsVector>
  1060. _ForwardIterator
  1061. __pattern_unique(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  1062. _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  1063. {
  1064. return __internal::__brick_unique(__first, __last, __pred, __is_vector);
  1065. }
  1066. // That function is shared between two algorithms - remove_if (__pattern_remove_if) and unique (pattern unique). But a mask calculation is different.
  1067. // So, a caller passes _CalcMask brick into remove_elements.
  1068. template <class _ExecutionPolicy, class _ForwardIterator, class _CalcMask, class _IsVector>
  1069. _ForwardIterator
  1070. __remove_elements(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _CalcMask __calc_mask,
  1071. _IsVector __is_vector)
  1072. {
  1073. typedef typename std::iterator_traits<_ForwardIterator>::difference_type _DifferenceType;
  1074. typedef typename std::iterator_traits<_ForwardIterator>::value_type _Tp;
  1075. _DifferenceType __n = __last - __first;
  1076. __par_backend::__buffer<bool> __mask_buf(__n);
  1077. // 1. find a first iterator that should be removed
  1078. return __internal::__except_handler([&]() {
  1079. bool* __mask = __mask_buf.get();
  1080. _DifferenceType __min = __par_backend::__parallel_reduce(
  1081. std::forward<_ExecutionPolicy>(__exec), _DifferenceType(0), __n, __n,
  1082. [__first, __mask, &__calc_mask, __is_vector](_DifferenceType __i, _DifferenceType __j,
  1083. _DifferenceType __local_min) -> _DifferenceType {
  1084. // Create mask
  1085. __calc_mask(__mask + __i, __mask + __j, __first + __i);
  1086. // if minimum was found in a previous range we shouldn't do anymore
  1087. if (__local_min < __i)
  1088. {
  1089. return __local_min;
  1090. }
  1091. // find first iterator that should be removed
  1092. bool* __result = __internal::__brick_find_if(__mask + __i, __mask + __j,
  1093. [](bool __val) { return !__val; }, __is_vector);
  1094. if (__result - __mask == __j)
  1095. {
  1096. return __local_min;
  1097. }
  1098. return std::min(__local_min, _DifferenceType(__result - __mask));
  1099. },
  1100. [](_DifferenceType __local_min1, _DifferenceType __local_min2) -> _DifferenceType {
  1101. return std::min(__local_min1, __local_min2);
  1102. });
  1103. // No elements to remove - exit
  1104. if (__min == __n)
  1105. {
  1106. return __last;
  1107. }
  1108. __n -= __min;
  1109. __first += __min;
  1110. __par_backend::__buffer<_Tp> __buf(__n);
  1111. _Tp* __result = __buf.get();
  1112. __mask += __min;
  1113. _DifferenceType __m{};
  1114. // 2. Elements that doesn't satisfy pred are moved to result
  1115. __par_backend::__parallel_strict_scan(
  1116. std::forward<_ExecutionPolicy>(__exec), __n, _DifferenceType(0),
  1117. [__mask, __is_vector](_DifferenceType __i, _DifferenceType __len) {
  1118. return __internal::__brick_count(__mask + __i, __mask + __i + __len, [](bool __val) { return __val; },
  1119. __is_vector);
  1120. },
  1121. std::plus<_DifferenceType>(),
  1122. [=](_DifferenceType __i, _DifferenceType __len, _DifferenceType __initial) {
  1123. __internal::__brick_copy_by_mask(
  1124. __first + __i, __first + __i + __len, __result + __initial, __mask + __i,
  1125. [](_ForwardIterator __x, _Tp* __z) {
  1126. __internal::__invoke_if_else(std::is_trivial<_Tp>(), [&]() { *__z = std::move(*__x); },
  1127. [&]() { ::new (std::addressof(*__z)) _Tp(std::move(*__x)); });
  1128. },
  1129. __is_vector);
  1130. },
  1131. [&__m](_DifferenceType __total) { __m = __total; });
  1132. // 3. Elements from result are moved to [first, last)
  1133. __par_backend::__parallel_for(
  1134. std::forward<_ExecutionPolicy>(__exec), __result, __result + __m,
  1135. [__result, __first, __is_vector](_Tp* __i, _Tp* __j) {
  1136. __invoke_if_else(
  1137. std::is_trivial<_Tp>(),
  1138. [&]() { __brick_move(__i, __j, __first + (__i - __result), __is_vector); },
  1139. [&]() {
  1140. __brick_move_destroy()(__i, __j, __first + (__i - __result), __is_vector);
  1141. });
  1142. });
  1143. return __first + __m;
  1144. });
  1145. }
  1146. template <class _ExecutionPolicy, class _ForwardIterator, class _BinaryPredicate, class _IsVector>
  1147. _ForwardIterator
  1148. __pattern_unique(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  1149. _IsVector __is_vector, /*is_parallel=*/std::true_type) noexcept
  1150. {
  1151. typedef typename std::iterator_traits<_ForwardIterator>::reference _ReferenceType;
  1152. if (__first == __last)
  1153. {
  1154. return __last;
  1155. }
  1156. if (__first + 1 == __last || __first + 2 == __last)
  1157. {
  1158. // Trivial sequence - use serial algorithm
  1159. return __internal::__brick_unique(__first, __last, __pred, __is_vector);
  1160. }
  1161. return __internal::__remove_elements(
  1162. std::forward<_ExecutionPolicy>(__exec), ++__first, __last,
  1163. [&__pred, __is_vector](bool* __b, bool* __e, _ForwardIterator __it) {
  1164. __internal::__brick_walk3(
  1165. __b, __e, __it - 1, __it,
  1166. [&__pred](bool& __x, _ReferenceType __y, _ReferenceType __z) { __x = !__pred(__y, __z); }, __is_vector);
  1167. },
  1168. __is_vector);
  1169. }
  1170. //------------------------------------------------------------------------
  1171. // unique_copy
  1172. //------------------------------------------------------------------------
  1173. template <class _ForwardIterator, class OutputIterator, class _BinaryPredicate>
  1174. OutputIterator
  1175. __brick_unique_copy(_ForwardIterator __first, _ForwardIterator __last, OutputIterator __result, _BinaryPredicate __pred,
  1176. /*vector=*/std::false_type) noexcept
  1177. {
  1178. return std::unique_copy(__first, __last, __result, __pred);
  1179. }
  1180. template <class _RandomAccessIterator, class OutputIterator, class _BinaryPredicate>
  1181. OutputIterator
  1182. __brick_unique_copy(_RandomAccessIterator __first, _RandomAccessIterator __last, OutputIterator __result,
  1183. _BinaryPredicate __pred, /*vector=*/std::true_type) noexcept
  1184. {
  1185. #if (_PSTL_MONOTONIC_PRESENT)
  1186. return __unseq_backend::__simd_unique_copy(__first, __last - __first, __result, __pred);
  1187. #else
  1188. return std::unique_copy(__first, __last, __result, __pred);
  1189. #endif
  1190. }
  1191. template <class _ExecutionPolicy, class _ForwardIterator, class _OutputIterator, class _BinaryPredicate,
  1192. class _IsVector>
  1193. _OutputIterator
  1194. __pattern_unique_copy(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result,
  1195. _BinaryPredicate __pred, _IsVector __is_vector, /*parallel=*/std::false_type) noexcept
  1196. {
  1197. return __internal::__brick_unique_copy(__first, __last, __result, __pred, __is_vector);
  1198. }
  1199. template <class _DifferenceType, class _RandomAccessIterator, class _BinaryPredicate>
  1200. _DifferenceType
  1201. __brick_calc_mask_2(_RandomAccessIterator __first, _RandomAccessIterator __last, bool* __restrict __mask,
  1202. _BinaryPredicate __pred, /*vector=*/std::false_type) noexcept
  1203. {
  1204. _DifferenceType __count = 0;
  1205. for (; __first != __last; ++__first, ++__mask)
  1206. {
  1207. *__mask = !__pred(*__first, *(__first - 1));
  1208. __count += *__mask;
  1209. }
  1210. return __count;
  1211. }
  1212. template <class _DifferenceType, class _RandomAccessIterator, class _BinaryPredicate>
  1213. _DifferenceType
  1214. __brick_calc_mask_2(_RandomAccessIterator __first, _RandomAccessIterator __last, bool* __restrict __mask,
  1215. _BinaryPredicate __pred, /*vector=*/std::true_type) noexcept
  1216. {
  1217. return __unseq_backend::__simd_calc_mask_2(__first, __last - __first, __mask, __pred);
  1218. }
  1219. template <class _ExecutionPolicy, class _RandomAccessIterator, class _OutputIterator, class _BinaryPredicate,
  1220. class _IsVector>
  1221. _OutputIterator
  1222. __pattern_unique_copy(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  1223. _OutputIterator __result, _BinaryPredicate __pred, _IsVector __is_vector,
  1224. /*parallel=*/std::true_type)
  1225. {
  1226. typedef typename std::iterator_traits<_RandomAccessIterator>::difference_type _DifferenceType;
  1227. const _DifferenceType __n = __last - __first;
  1228. if (_DifferenceType(2) < __n)
  1229. {
  1230. __par_backend::__buffer<bool> __mask_buf(__n);
  1231. if (_DifferenceType(2) < __n)
  1232. {
  1233. return __internal::__except_handler([&__exec, __n, __first, __result, __pred, __is_vector, &__mask_buf]() {
  1234. bool* __mask = __mask_buf.get();
  1235. _DifferenceType __m{};
  1236. __par_backend::__parallel_strict_scan(
  1237. std::forward<_ExecutionPolicy>(__exec), __n, _DifferenceType(0),
  1238. [=](_DifferenceType __i, _DifferenceType __len) -> _DifferenceType { // Reduce
  1239. _DifferenceType __extra = 0;
  1240. if (__i == 0)
  1241. {
  1242. // Special boundary case
  1243. __mask[__i] = true;
  1244. if (--__len == 0)
  1245. return 1;
  1246. ++__i;
  1247. ++__extra;
  1248. }
  1249. return __internal::__brick_calc_mask_2<_DifferenceType>(__first + __i, __first + (__i + __len),
  1250. __mask + __i, __pred, __is_vector) +
  1251. __extra;
  1252. },
  1253. std::plus<_DifferenceType>(), // Combine
  1254. [=](_DifferenceType __i, _DifferenceType __len, _DifferenceType __initial) { // Scan
  1255. // Phase 2 is same as for __pattern_copy_if
  1256. __internal::__brick_copy_by_mask(
  1257. __first + __i, __first + (__i + __len), __result + __initial, __mask + __i,
  1258. [](_RandomAccessIterator __x, _OutputIterator __z) { *__z = *__x; }, __is_vector);
  1259. },
  1260. [&__m](_DifferenceType __total) { __m = __total; });
  1261. return __result + __m;
  1262. });
  1263. }
  1264. }
  1265. // trivial sequence - use serial algorithm
  1266. return __internal::__brick_unique_copy(__first, __last, __result, __pred, __is_vector);
  1267. }
  1268. //------------------------------------------------------------------------
  1269. // reverse
  1270. //------------------------------------------------------------------------
  1271. template <class _BidirectionalIterator>
  1272. void
  1273. __brick_reverse(_BidirectionalIterator __first, _BidirectionalIterator __last, /*__is_vector=*/std::false_type) noexcept
  1274. {
  1275. std::reverse(__first, __last);
  1276. }
  1277. template <class _BidirectionalIterator>
  1278. void
  1279. __brick_reverse(_BidirectionalIterator __first, _BidirectionalIterator __last, /*__is_vector=*/std::true_type) noexcept
  1280. {
  1281. typedef typename std::iterator_traits<_BidirectionalIterator>::reference _ReferenceType;
  1282. const auto __n = (__last - __first) / 2;
  1283. __unseq_backend::__simd_walk_2(__first, __n, std::reverse_iterator<_BidirectionalIterator>(__last),
  1284. [](_ReferenceType __x, _ReferenceType __y) {
  1285. using std::swap;
  1286. swap(__x, __y);
  1287. });
  1288. }
  1289. // this brick is called in parallel version, so we can use iterator arithmetic
  1290. template <class _BidirectionalIterator>
  1291. void
  1292. __brick_reverse(_BidirectionalIterator __first, _BidirectionalIterator __last, _BidirectionalIterator __d_last,
  1293. /*is_vector=*/std::false_type) noexcept
  1294. {
  1295. for (--__d_last; __first != __last; ++__first, --__d_last)
  1296. {
  1297. using std::iter_swap;
  1298. iter_swap(__first, __d_last);
  1299. }
  1300. }
  1301. // this brick is called in parallel version, so we can use iterator arithmetic
  1302. template <class _BidirectionalIterator>
  1303. void
  1304. __brick_reverse(_BidirectionalIterator __first, _BidirectionalIterator __last, _BidirectionalIterator __d_last,
  1305. /*is_vector=*/std::true_type) noexcept
  1306. {
  1307. typedef typename std::iterator_traits<_BidirectionalIterator>::reference _ReferenceType;
  1308. __unseq_backend::__simd_walk_2(__first, __last - __first, std::reverse_iterator<_BidirectionalIterator>(__d_last),
  1309. [](_ReferenceType __x, _ReferenceType __y) {
  1310. using std::swap;
  1311. swap(__x, __y);
  1312. });
  1313. }
  1314. template <class _ExecutionPolicy, class _BidirectionalIterator, class _IsVector>
  1315. void
  1316. __pattern_reverse(_ExecutionPolicy&&, _BidirectionalIterator __first, _BidirectionalIterator __last,
  1317. _IsVector _is_vector,
  1318. /*is_parallel=*/std::false_type) noexcept
  1319. {
  1320. __internal::__brick_reverse(__first, __last, _is_vector);
  1321. }
  1322. template <class _ExecutionPolicy, class _BidirectionalIterator, class _IsVector>
  1323. void
  1324. __pattern_reverse(_ExecutionPolicy&& __exec, _BidirectionalIterator __first, _BidirectionalIterator __last,
  1325. _IsVector __is_vector, /*is_parallel=*/std::true_type)
  1326. {
  1327. __par_backend::__parallel_for(
  1328. std::forward<_ExecutionPolicy>(__exec), __first, __first + (__last - __first) / 2,
  1329. [__is_vector, __first, __last](_BidirectionalIterator __inner_first, _BidirectionalIterator __inner_last) {
  1330. __internal::__brick_reverse(__inner_first, __inner_last, __last - (__inner_first - __first), __is_vector);
  1331. });
  1332. }
  1333. //------------------------------------------------------------------------
  1334. // reverse_copy
  1335. //------------------------------------------------------------------------
  1336. template <class _BidirectionalIterator, class _OutputIterator>
  1337. _OutputIterator
  1338. __brick_reverse_copy(_BidirectionalIterator __first, _BidirectionalIterator __last, _OutputIterator __d_first,
  1339. /*is_vector=*/std::false_type) noexcept
  1340. {
  1341. return std::reverse_copy(__first, __last, __d_first);
  1342. }
  1343. template <class _BidirectionalIterator, class _OutputIterator>
  1344. _OutputIterator
  1345. __brick_reverse_copy(_BidirectionalIterator __first, _BidirectionalIterator __last, _OutputIterator __d_first,
  1346. /*is_vector=*/std::true_type) noexcept
  1347. {
  1348. typedef typename std::iterator_traits<_BidirectionalIterator>::reference _ReferenceType1;
  1349. typedef typename std::iterator_traits<_OutputIterator>::reference _ReferenceType2;
  1350. return __unseq_backend::__simd_walk_2(std::reverse_iterator<_BidirectionalIterator>(__last), __last - __first,
  1351. __d_first, [](_ReferenceType1 __x, _ReferenceType2 __y) { __y = __x; });
  1352. }
  1353. template <class _ExecutionPolicy, class _BidirectionalIterator, class _OutputIterator, class _IsVector>
  1354. _OutputIterator
  1355. __pattern_reverse_copy(_ExecutionPolicy&&, _BidirectionalIterator __first, _BidirectionalIterator __last,
  1356. _OutputIterator __d_first, _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  1357. {
  1358. return __internal::__brick_reverse_copy(__first, __last, __d_first, __is_vector);
  1359. }
  1360. template <class _ExecutionPolicy, class _BidirectionalIterator, class _OutputIterator, class _IsVector>
  1361. _OutputIterator
  1362. __pattern_reverse_copy(_ExecutionPolicy&& __exec, _BidirectionalIterator __first, _BidirectionalIterator __last,
  1363. _OutputIterator __d_first, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  1364. {
  1365. auto __len = __last - __first;
  1366. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  1367. [__is_vector, __first, __len, __d_first](_BidirectionalIterator __inner_first,
  1368. _BidirectionalIterator __inner_last) {
  1369. __internal::__brick_reverse_copy(__inner_first, __inner_last,
  1370. __d_first + (__len - (__inner_last - __first)),
  1371. __is_vector);
  1372. });
  1373. return __d_first + __len;
  1374. }
  1375. //------------------------------------------------------------------------
  1376. // rotate
  1377. //------------------------------------------------------------------------
  1378. template <class _ForwardIterator>
  1379. _ForwardIterator
  1380. __brick_rotate(_ForwardIterator __first, _ForwardIterator __middle, _ForwardIterator __last,
  1381. /*is_vector=*/std::false_type) noexcept
  1382. {
  1383. #if _PSTL_CPP11_STD_ROTATE_BROKEN
  1384. std::rotate(__first, __middle, __last);
  1385. return std::next(__first, std::distance(__middle, __last));
  1386. #else
  1387. return std::rotate(__first, __middle, __last);
  1388. #endif
  1389. }
  1390. template <class _ForwardIterator>
  1391. _ForwardIterator
  1392. __brick_rotate(_ForwardIterator __first, _ForwardIterator __middle, _ForwardIterator __last,
  1393. /*is_vector=*/std::true_type) noexcept
  1394. {
  1395. auto __n = __last - __first;
  1396. auto __m = __middle - __first;
  1397. const _ForwardIterator __ret = __first + (__last - __middle);
  1398. bool __is_left = (__m <= __n / 2);
  1399. if (!__is_left)
  1400. __m = __n - __m;
  1401. while (__n > 1 && __m > 0)
  1402. {
  1403. using std::iter_swap;
  1404. const auto __m_2 = __m * 2;
  1405. if (__is_left)
  1406. {
  1407. for (; __last - __first >= __m_2; __first += __m)
  1408. {
  1409. __unseq_backend::__simd_assign(__first, __m, __first + __m,
  1410. iter_swap<_ForwardIterator, _ForwardIterator>);
  1411. }
  1412. }
  1413. else
  1414. {
  1415. for (; __last - __first >= __m_2; __last -= __m)
  1416. {
  1417. __unseq_backend::__simd_assign(__last - __m, __m, __last - __m_2,
  1418. iter_swap<_ForwardIterator, _ForwardIterator>);
  1419. }
  1420. }
  1421. __is_left = !__is_left;
  1422. __m = __n % __m;
  1423. __n = __last - __first;
  1424. }
  1425. return __ret;
  1426. }
  1427. template <class _ExecutionPolicy, class _ForwardIterator, class _IsVector>
  1428. _ForwardIterator
  1429. __pattern_rotate(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __middle, _ForwardIterator __last,
  1430. _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  1431. {
  1432. return __internal::__brick_rotate(__first, __middle, __last, __is_vector);
  1433. }
  1434. template <class _ExecutionPolicy, class _ForwardIterator, class _IsVector>
  1435. _ForwardIterator
  1436. __pattern_rotate(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __middle,
  1437. _ForwardIterator __last, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  1438. {
  1439. typedef typename std::iterator_traits<_ForwardIterator>::value_type _Tp;
  1440. auto __n = __last - __first;
  1441. auto __m = __middle - __first;
  1442. if (__m <= __n / 2)
  1443. {
  1444. __par_backend::__buffer<_Tp> __buf(__n - __m);
  1445. return __internal::__except_handler([&__exec, __n, __m, __first, __middle, __last, __is_vector, &__buf]() {
  1446. _Tp* __result = __buf.get();
  1447. __par_backend::__parallel_for(
  1448. std::forward<_ExecutionPolicy>(__exec), __middle, __last,
  1449. [__middle, __result, __is_vector](_ForwardIterator __b, _ForwardIterator __e) {
  1450. __internal::__brick_uninitialized_move(__b, __e, __result + (__b - __middle), __is_vector);
  1451. });
  1452. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __middle,
  1453. [__last, __middle, __is_vector](_ForwardIterator __b, _ForwardIterator __e) {
  1454. __internal::__brick_move(__b, __e, __b + (__last - __middle),
  1455. __is_vector);
  1456. });
  1457. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __result, __result + (__n - __m),
  1458. [__first, __result, __is_vector](_Tp* __b, _Tp* __e) {
  1459. __brick_move_destroy()(
  1460. __b, __e, __first + (__b - __result), __is_vector);
  1461. });
  1462. return __first + (__last - __middle);
  1463. });
  1464. }
  1465. else
  1466. {
  1467. __par_backend::__buffer<_Tp> __buf(__m);
  1468. return __internal::__except_handler([&__exec, __n, __m, __first, __middle, __last, __is_vector, &__buf]() {
  1469. _Tp* __result = __buf.get();
  1470. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __middle,
  1471. [__first, __result, __is_vector](_ForwardIterator __b, _ForwardIterator __e) {
  1472. __internal::__brick_uninitialized_move(
  1473. __b, __e, __result + (__b - __first), __is_vector);
  1474. });
  1475. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __middle, __last,
  1476. [__first, __middle, __is_vector](_ForwardIterator __b, _ForwardIterator __e) {
  1477. __internal::__brick_move(__b, __e, __first + (__b - __middle),
  1478. __is_vector);
  1479. });
  1480. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __result, __result + __m,
  1481. [__n, __m, __first, __result, __is_vector](_Tp* __b, _Tp* __e) {
  1482. __brick_move_destroy()(
  1483. __b, __e, __first + ((__n - __m) + (__b - __result)), __is_vector);
  1484. });
  1485. return __first + (__last - __middle);
  1486. });
  1487. }
  1488. }
  1489. //------------------------------------------------------------------------
  1490. // rotate_copy
  1491. //------------------------------------------------------------------------
  1492. template <class _ForwardIterator, class _OutputIterator>
  1493. _OutputIterator
  1494. __brick_rotate_copy(_ForwardIterator __first, _ForwardIterator __middle, _ForwardIterator __last,
  1495. _OutputIterator __result, /*__is_vector=*/std::false_type) noexcept
  1496. {
  1497. return std::rotate_copy(__first, __middle, __last, __result);
  1498. }
  1499. template <class _ForwardIterator, class _OutputIterator>
  1500. _OutputIterator
  1501. __brick_rotate_copy(_ForwardIterator __first, _ForwardIterator __middle, _ForwardIterator __last,
  1502. _OutputIterator __result, /*__is_vector=*/std::true_type) noexcept
  1503. {
  1504. _OutputIterator __res = __internal::__brick_copy(__middle, __last, __result, std::true_type());
  1505. return __internal::__brick_copy(__first, __middle, __res, std::true_type());
  1506. }
  1507. template <class _ExecutionPolicy, class _ForwardIterator, class _OutputIterator, class _IsVector>
  1508. _OutputIterator
  1509. __pattern_rotate_copy(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __middle, _ForwardIterator __last,
  1510. _OutputIterator __result, _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  1511. {
  1512. return __internal::__brick_rotate_copy(__first, __middle, __last, __result, __is_vector);
  1513. }
  1514. template <class _ExecutionPolicy, class _ForwardIterator, class _OutputIterator, class _IsVector>
  1515. _OutputIterator
  1516. __pattern_rotate_copy(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __middle,
  1517. _ForwardIterator __last, _OutputIterator __result, _IsVector __is_vector,
  1518. /*is_parallel=*/std::true_type)
  1519. {
  1520. __par_backend::__parallel_for(
  1521. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  1522. [__first, __last, __middle, __result, __is_vector](_ForwardIterator __b, _ForwardIterator __e) {
  1523. if (__b > __middle)
  1524. {
  1525. __internal::__brick_copy(__b, __e, __result + (__b - __middle), __is_vector);
  1526. }
  1527. else
  1528. {
  1529. _OutputIterator __new_result = __result + ((__last - __middle) + (__b - __first));
  1530. if (__e < __middle)
  1531. {
  1532. __internal::__brick_copy(__b, __e, __new_result, __is_vector);
  1533. }
  1534. else
  1535. {
  1536. __internal::__brick_copy(__b, __middle, __new_result, __is_vector);
  1537. __internal::__brick_copy(__middle, __e, __result, __is_vector);
  1538. }
  1539. }
  1540. });
  1541. return __result + (__last - __first);
  1542. }
  1543. //------------------------------------------------------------------------
  1544. // is_partitioned
  1545. //------------------------------------------------------------------------
  1546. template <class _ForwardIterator, class _UnaryPredicate>
  1547. bool
  1548. __brick_is_partitioned(_ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  1549. /*is_vector=*/std::false_type) noexcept
  1550. {
  1551. return std::is_partitioned(__first, __last, __pred);
  1552. }
  1553. template <class _ForwardIterator, class _UnaryPredicate>
  1554. bool
  1555. __brick_is_partitioned(_ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  1556. /*is_vector=*/std::true_type) noexcept
  1557. {
  1558. typedef typename std::iterator_traits<_ForwardIterator>::difference_type _SizeType;
  1559. if (__first == __last)
  1560. {
  1561. return true;
  1562. }
  1563. else
  1564. {
  1565. _ForwardIterator __result = __unseq_backend::__simd_first(
  1566. __first, _SizeType(0), __last - __first,
  1567. [&__pred](_ForwardIterator __it, _SizeType __i) { return !__pred(__it[__i]); });
  1568. if (__result == __last)
  1569. {
  1570. return true;
  1571. }
  1572. else
  1573. {
  1574. ++__result;
  1575. return !__unseq_backend::__simd_or(__result, __last - __result, __pred);
  1576. }
  1577. }
  1578. }
  1579. template <class _ExecutionPolicy, class _ForwardIterator, class _UnaryPredicate, class _IsVector>
  1580. bool
  1581. __pattern_is_partitioned(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  1582. _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  1583. {
  1584. return __internal::__brick_is_partitioned(__first, __last, __pred, __is_vector);
  1585. }
  1586. template <class _ExecutionPolicy, class _ForwardIterator, class _UnaryPredicate, class _IsVector>
  1587. bool
  1588. __pattern_is_partitioned(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last,
  1589. _UnaryPredicate __pred, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  1590. {
  1591. if (__first == __last)
  1592. {
  1593. return true;
  1594. }
  1595. else
  1596. {
  1597. return __internal::__except_handler([&]() {
  1598. // State of current range:
  1599. // broken - current range is not partitioned by pred
  1600. // all_true - all elements in current range satisfy pred
  1601. // all_false - all elements in current range don't satisfy pred
  1602. // true_false - elements satisfy pred are placed before elements that don't satisfy pred
  1603. enum _ReduceType
  1604. {
  1605. __not_init = -1,
  1606. __broken,
  1607. __all_true,
  1608. __all_false,
  1609. __true_false
  1610. };
  1611. _ReduceType __init = __not_init;
  1612. // Array with states that we'll have when state from the left branch is merged with state from the right branch.
  1613. // State is calculated by formula: new_state = table[left_state * 4 + right_state]
  1614. _ReduceType __table[] = {__broken, __broken, __broken, __broken, __broken, __all_true,
  1615. __true_false, __true_false, __broken, __broken, __all_false, __broken,
  1616. __broken, __broken, __true_false, __broken};
  1617. __init = __par_backend::__parallel_reduce(
  1618. std::forward<_ExecutionPolicy>(__exec), __first, __last, __init,
  1619. [&__pred, &__table, __is_vector](_ForwardIterator __i, _ForwardIterator __j,
  1620. _ReduceType __value) -> _ReduceType {
  1621. if (__value == __broken)
  1622. {
  1623. return __broken;
  1624. }
  1625. _ReduceType __res = __not_init;
  1626. // if first element satisfy pred
  1627. if (__pred(*__i))
  1628. {
  1629. // find first element that don't satisfy pred
  1630. _ForwardIterator __x =
  1631. __internal::__brick_find_if(__i + 1, __j, std::not_fn(__pred), __is_vector);
  1632. if (__x != __j)
  1633. {
  1634. // find first element after "x" that satisfy pred
  1635. _ForwardIterator __y = __internal::__brick_find_if(__x + 1, __j, __pred, __is_vector);
  1636. // if it was found then range isn't partitioned by pred
  1637. if (__y != __j)
  1638. {
  1639. return __broken;
  1640. }
  1641. else
  1642. {
  1643. __res = __true_false;
  1644. }
  1645. }
  1646. else
  1647. {
  1648. __res = __all_true;
  1649. }
  1650. }
  1651. else
  1652. { // if first element doesn't satisfy pred
  1653. // then we should find the first element that satisfy pred.
  1654. // If we found it then range isn't partitioned by pred
  1655. if (__internal::__brick_find_if(__i + 1, __j, __pred, __is_vector) != __j)
  1656. {
  1657. return __broken;
  1658. }
  1659. else
  1660. {
  1661. __res = __all_false;
  1662. }
  1663. }
  1664. // if we have value from left range then we should calculate the result
  1665. return (__value == -1) ? __res : __table[__value * 4 + __res];
  1666. },
  1667. [&__table](_ReduceType __val1, _ReduceType __val2) -> _ReduceType {
  1668. if (__val1 == __broken || __val2 == __broken)
  1669. {
  1670. return __broken;
  1671. }
  1672. // calculate the result for new big range
  1673. return __table[__val1 * 4 + __val2];
  1674. });
  1675. return __init != __broken;
  1676. });
  1677. }
  1678. }
  1679. //------------------------------------------------------------------------
  1680. // partition
  1681. //------------------------------------------------------------------------
  1682. template <class _ForwardIterator, class _UnaryPredicate>
  1683. _ForwardIterator
  1684. __brick_partition(_ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  1685. /*is_vector=*/std::false_type) noexcept
  1686. {
  1687. return std::partition(__first, __last, __pred);
  1688. }
  1689. template <class _ForwardIterator, class _UnaryPredicate>
  1690. _ForwardIterator
  1691. __brick_partition(_ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  1692. /*is_vector=*/std::true_type) noexcept
  1693. {
  1694. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  1695. return std::partition(__first, __last, __pred);
  1696. }
  1697. template <class _ExecutionPolicy, class _ForwardIterator, class _UnaryPredicate, class _IsVector>
  1698. _ForwardIterator
  1699. __pattern_partition(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  1700. _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  1701. {
  1702. return __internal::__brick_partition(__first, __last, __pred, __is_vector);
  1703. }
  1704. template <class _ExecutionPolicy, class _ForwardIterator, class _UnaryPredicate, class _IsVector>
  1705. _ForwardIterator
  1706. __pattern_partition(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last,
  1707. _UnaryPredicate __pred, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  1708. {
  1709. // partitioned range: elements before pivot satisfy pred (true part),
  1710. // elements after pivot don't satisfy pred (false part)
  1711. struct _PartitionRange
  1712. {
  1713. _ForwardIterator __begin;
  1714. _ForwardIterator __pivot;
  1715. _ForwardIterator __end;
  1716. };
  1717. return __internal::__except_handler([&]() {
  1718. _PartitionRange __init{__last, __last, __last};
  1719. // lambda for merging two partitioned ranges to one partitioned range
  1720. auto __reductor = [&__exec, __is_vector](_PartitionRange __val1, _PartitionRange __val2) -> _PartitionRange {
  1721. auto __size1 = __val1.__end - __val1.__pivot;
  1722. auto __size2 = __val2.__pivot - __val2.__begin;
  1723. auto __new_begin = __val2.__begin - (__val1.__end - __val1.__begin);
  1724. // if all elements in left range satisfy pred then we can move new pivot to pivot of right range
  1725. if (__val1.__end == __val1.__pivot)
  1726. {
  1727. return {__new_begin, __val2.__pivot, __val2.__end};
  1728. }
  1729. // if true part of right range greater than false part of left range
  1730. // then we should swap the false part of left range and last part of true part of right range
  1731. else if (__size2 > __size1)
  1732. {
  1733. __par_backend::__parallel_for(
  1734. std::forward<_ExecutionPolicy>(__exec), __val1.__pivot, __val1.__pivot + __size1,
  1735. [__val1, __val2, __size1, __is_vector](_ForwardIterator __i, _ForwardIterator __j) {
  1736. __internal::__brick_swap_ranges(__i, __j, (__val2.__pivot - __size1) + (__i - __val1.__pivot),
  1737. __is_vector);
  1738. });
  1739. return {__new_begin, __val2.__pivot - __size1, __val2.__end};
  1740. }
  1741. // else we should swap the first part of false part of left range and true part of right range
  1742. else
  1743. {
  1744. __par_backend::__parallel_for(
  1745. std::forward<_ExecutionPolicy>(__exec), __val1.__pivot, __val1.__pivot + __size2,
  1746. [__val1, __val2, __is_vector](_ForwardIterator __i, _ForwardIterator __j) {
  1747. __internal::__brick_swap_ranges(__i, __j, __val2.__begin + (__i - __val1.__pivot), __is_vector);
  1748. });
  1749. return {__new_begin, __val1.__pivot + __size2, __val2.__end};
  1750. }
  1751. };
  1752. _PartitionRange __result = __par_backend::__parallel_reduce(
  1753. std::forward<_ExecutionPolicy>(__exec), __first, __last, __init,
  1754. [__pred, __is_vector, __reductor](_ForwardIterator __i, _ForwardIterator __j,
  1755. _PartitionRange __value) -> _PartitionRange {
  1756. //1. serial partition
  1757. _ForwardIterator __pivot = __internal::__brick_partition(__i, __j, __pred, __is_vector);
  1758. // 2. merging of two ranges (left and right respectively)
  1759. return __reductor(__value, {__i, __pivot, __j});
  1760. },
  1761. __reductor);
  1762. return __result.__pivot;
  1763. });
  1764. }
  1765. //------------------------------------------------------------------------
  1766. // stable_partition
  1767. //------------------------------------------------------------------------
  1768. template <class _BidirectionalIterator, class _UnaryPredicate>
  1769. _BidirectionalIterator
  1770. __brick_stable_partition(_BidirectionalIterator __first, _BidirectionalIterator __last, _UnaryPredicate __pred,
  1771. /*__is_vector=*/std::false_type) noexcept
  1772. {
  1773. return std::stable_partition(__first, __last, __pred);
  1774. }
  1775. template <class _BidirectionalIterator, class _UnaryPredicate>
  1776. _BidirectionalIterator
  1777. __brick_stable_partition(_BidirectionalIterator __first, _BidirectionalIterator __last, _UnaryPredicate __pred,
  1778. /*__is_vector=*/std::true_type) noexcept
  1779. {
  1780. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  1781. return std::stable_partition(__first, __last, __pred);
  1782. }
  1783. template <class _ExecutionPolicy, class _BidirectionalIterator, class _UnaryPredicate, class _IsVector>
  1784. _BidirectionalIterator
  1785. __pattern_stable_partition(_ExecutionPolicy&&, _BidirectionalIterator __first, _BidirectionalIterator __last,
  1786. _UnaryPredicate __pred, _IsVector __is_vector,
  1787. /*is_parallelization=*/std::false_type) noexcept
  1788. {
  1789. return __internal::__brick_stable_partition(__first, __last, __pred, __is_vector);
  1790. }
  1791. template <class _ExecutionPolicy, class _BidirectionalIterator, class _UnaryPredicate, class _IsVector>
  1792. _BidirectionalIterator
  1793. __pattern_stable_partition(_ExecutionPolicy&& __exec, _BidirectionalIterator __first, _BidirectionalIterator __last,
  1794. _UnaryPredicate __pred, _IsVector __is_vector,
  1795. /*is_parallelization=*/std::true_type) noexcept
  1796. {
  1797. // partitioned range: elements before pivot satisfy pred (true part),
  1798. // elements after pivot don't satisfy pred (false part)
  1799. struct _PartitionRange
  1800. {
  1801. _BidirectionalIterator __begin;
  1802. _BidirectionalIterator __pivot;
  1803. _BidirectionalIterator __end;
  1804. };
  1805. return __internal::__except_handler([&]() {
  1806. _PartitionRange __init{__last, __last, __last};
  1807. // lambda for merging two partitioned ranges to one partitioned range
  1808. auto __reductor = [__is_vector](_PartitionRange __val1, _PartitionRange __val2) -> _PartitionRange {
  1809. auto __size1 = __val1.__end - __val1.__pivot;
  1810. auto __new_begin = __val2.__begin - (__val1.__end - __val1.__begin);
  1811. // if all elements in left range satisfy pred then we can move new pivot to pivot of right range
  1812. if (__val1.__end == __val1.__pivot)
  1813. {
  1814. return {__new_begin, __val2.__pivot, __val2.__end};
  1815. }
  1816. // if true part of right range greater than false part of left range
  1817. // then we should swap the false part of left range and last part of true part of right range
  1818. else
  1819. {
  1820. __internal::__brick_rotate(__val1.__pivot, __val2.__begin, __val2.__pivot, __is_vector);
  1821. return {__new_begin, __val2.__pivot - __size1, __val2.__end};
  1822. }
  1823. };
  1824. _PartitionRange __result = __par_backend::__parallel_reduce(
  1825. std::forward<_ExecutionPolicy>(__exec), __first, __last, __init,
  1826. [&__pred, __is_vector, __reductor](_BidirectionalIterator __i, _BidirectionalIterator __j,
  1827. _PartitionRange __value) -> _PartitionRange {
  1828. //1. serial stable_partition
  1829. _BidirectionalIterator __pivot = __internal::__brick_stable_partition(__i, __j, __pred, __is_vector);
  1830. // 2. merging of two ranges (left and right respectively)
  1831. return __reductor(__value, {__i, __pivot, __j});
  1832. },
  1833. __reductor);
  1834. return __result.__pivot;
  1835. });
  1836. }
  1837. //------------------------------------------------------------------------
  1838. // partition_copy
  1839. //------------------------------------------------------------------------
  1840. template <class _ForwardIterator, class _OutputIterator1, class _OutputIterator2, class _UnaryPredicate>
  1841. std::pair<_OutputIterator1, _OutputIterator2>
  1842. __brick_partition_copy(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator1 __out_true,
  1843. _OutputIterator2 __out_false, _UnaryPredicate __pred, /*is_vector=*/std::false_type) noexcept
  1844. {
  1845. return std::partition_copy(__first, __last, __out_true, __out_false, __pred);
  1846. }
  1847. template <class _ForwardIterator, class _OutputIterator1, class _OutputIterator2, class _UnaryPredicate>
  1848. std::pair<_OutputIterator1, _OutputIterator2>
  1849. __brick_partition_copy(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator1 __out_true,
  1850. _OutputIterator2 __out_false, _UnaryPredicate __pred, /*is_vector=*/std::true_type) noexcept
  1851. {
  1852. #if (_PSTL_MONOTONIC_PRESENT)
  1853. return __unseq_backend::__simd_partition_copy(__first, __last - __first, __out_true, __out_false, __pred);
  1854. #else
  1855. return std::partition_copy(__first, __last, __out_true, __out_false, __pred);
  1856. #endif
  1857. }
  1858. template <class _ExecutionPolicy, class _ForwardIterator, class _OutputIterator1, class _OutputIterator2,
  1859. class _UnaryPredicate, class _IsVector>
  1860. std::pair<_OutputIterator1, _OutputIterator2>
  1861. __pattern_partition_copy(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last,
  1862. _OutputIterator1 __out_true, _OutputIterator2 __out_false, _UnaryPredicate __pred,
  1863. _IsVector __is_vector, /*is_parallelization=*/std::false_type) noexcept
  1864. {
  1865. return __internal::__brick_partition_copy(__first, __last, __out_true, __out_false, __pred, __is_vector);
  1866. }
  1867. template <class _ExecutionPolicy, class _RandomAccessIterator, class _OutputIterator1, class _OutputIterator2,
  1868. class _UnaryPredicate, class _IsVector>
  1869. std::pair<_OutputIterator1, _OutputIterator2>
  1870. __pattern_partition_copy(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  1871. _OutputIterator1 __out_true, _OutputIterator2 __out_false, _UnaryPredicate __pred,
  1872. _IsVector __is_vector, /*is_parallelization=*/std::true_type)
  1873. {
  1874. typedef typename std::iterator_traits<_RandomAccessIterator>::difference_type _DifferenceType;
  1875. typedef std::pair<_DifferenceType, _DifferenceType> _ReturnType;
  1876. const _DifferenceType __n = __last - __first;
  1877. if (_DifferenceType(1) < __n)
  1878. {
  1879. __par_backend::__buffer<bool> __mask_buf(__n);
  1880. return __internal::__except_handler([&__exec, __n, __first, __out_true, __out_false, __is_vector, __pred,
  1881. &__mask_buf]() {
  1882. bool* __mask = __mask_buf.get();
  1883. _ReturnType __m{};
  1884. __par_backend::__parallel_strict_scan(
  1885. std::forward<_ExecutionPolicy>(__exec), __n, std::make_pair(_DifferenceType(0), _DifferenceType(0)),
  1886. [=](_DifferenceType __i, _DifferenceType __len) { // Reduce
  1887. return __internal::__brick_calc_mask_1<_DifferenceType>(__first + __i, __first + (__i + __len),
  1888. __mask + __i, __pred, __is_vector);
  1889. },
  1890. [](const _ReturnType& __x, const _ReturnType& __y) -> _ReturnType {
  1891. return std::make_pair(__x.first + __y.first, __x.second + __y.second);
  1892. }, // Combine
  1893. [=](_DifferenceType __i, _DifferenceType __len, _ReturnType __initial) { // Scan
  1894. __internal::__brick_partition_by_mask(__first + __i, __first + (__i + __len),
  1895. __out_true + __initial.first, __out_false + __initial.second,
  1896. __mask + __i, __is_vector);
  1897. },
  1898. [&__m](_ReturnType __total) { __m = __total; });
  1899. return std::make_pair(__out_true + __m.first, __out_false + __m.second);
  1900. });
  1901. }
  1902. // trivial sequence - use serial algorithm
  1903. return __internal::__brick_partition_copy(__first, __last, __out_true, __out_false, __pred, __is_vector);
  1904. }
  1905. //------------------------------------------------------------------------
  1906. // sort
  1907. //------------------------------------------------------------------------
  1908. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector,
  1909. class _IsMoveConstructible>
  1910. void
  1911. __pattern_sort(_ExecutionPolicy&&, _RandomAccessIterator __first, _RandomAccessIterator __last, _Compare __comp,
  1912. _IsVector /*is_vector*/, /*is_parallel=*/std::false_type, _IsMoveConstructible) noexcept
  1913. {
  1914. std::sort(__first, __last, __comp);
  1915. }
  1916. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  1917. void
  1918. __pattern_sort(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last, _Compare __comp,
  1919. _IsVector /*is_vector*/, /*is_parallel=*/std::true_type, /*is_move_constructible=*/std::true_type)
  1920. {
  1921. __internal::__except_handler([&]() {
  1922. __par_backend::__parallel_stable_sort(std::forward<_ExecutionPolicy>(__exec), __first, __last, __comp,
  1923. [](_RandomAccessIterator __first, _RandomAccessIterator __last,
  1924. _Compare __comp) { std::sort(__first, __last, __comp); });
  1925. });
  1926. }
  1927. //------------------------------------------------------------------------
  1928. // stable_sort
  1929. //------------------------------------------------------------------------
  1930. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  1931. void
  1932. __pattern_stable_sort(_ExecutionPolicy&&, _RandomAccessIterator __first, _RandomAccessIterator __last, _Compare __comp,
  1933. _IsVector /*is_vector*/, /*is_parallel=*/std::false_type) noexcept
  1934. {
  1935. std::stable_sort(__first, __last, __comp);
  1936. }
  1937. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  1938. void
  1939. __pattern_stable_sort(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  1940. _Compare __comp, _IsVector /*is_vector*/, /*is_parallel=*/std::true_type)
  1941. {
  1942. __internal::__except_handler([&]() {
  1943. __par_backend::__parallel_stable_sort(std::forward<_ExecutionPolicy>(__exec), __first, __last, __comp,
  1944. [](_RandomAccessIterator __first, _RandomAccessIterator __last,
  1945. _Compare __comp) { std::stable_sort(__first, __last, __comp); });
  1946. });
  1947. }
  1948. //------------------------------------------------------------------------
  1949. // partial_sort
  1950. //------------------------------------------------------------------------
  1951. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  1952. void
  1953. __pattern_partial_sort(_ExecutionPolicy&&, _RandomAccessIterator __first, _RandomAccessIterator __middle,
  1954. _RandomAccessIterator __last, _Compare __comp, _IsVector,
  1955. /*is_parallel=*/std::false_type) noexcept
  1956. {
  1957. std::partial_sort(__first, __middle, __last, __comp);
  1958. }
  1959. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  1960. void
  1961. __pattern_partial_sort(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __middle,
  1962. _RandomAccessIterator __last, _Compare __comp, _IsVector, /*is_parallel=*/std::true_type)
  1963. {
  1964. const auto __n = __middle - __first;
  1965. if (__n == 0)
  1966. return;
  1967. __internal::__except_handler([&]() {
  1968. __par_backend::__parallel_stable_sort(
  1969. std::forward<_ExecutionPolicy>(__exec), __first, __last, __comp,
  1970. [__n](_RandomAccessIterator __begin, _RandomAccessIterator __end, _Compare __comp) {
  1971. if (__n < __end - __begin)
  1972. std::partial_sort(__begin, __begin + __n, __end, __comp);
  1973. else
  1974. std::sort(__begin, __end, __comp);
  1975. },
  1976. __n);
  1977. });
  1978. }
  1979. //------------------------------------------------------------------------
  1980. // partial_sort_copy
  1981. //------------------------------------------------------------------------
  1982. template <class _ExecutionPolicy, class _ForwardIterator, class _RandomAccessIterator, class _Compare, class _IsVector>
  1983. _RandomAccessIterator
  1984. __pattern_partial_sort_copy(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last,
  1985. _RandomAccessIterator __d_first, _RandomAccessIterator __d_last, _Compare __comp, _IsVector,
  1986. /*is_parallel=*/std::false_type) noexcept
  1987. {
  1988. return std::partial_sort_copy(__first, __last, __d_first, __d_last, __comp);
  1989. }
  1990. template <class _ExecutionPolicy, class _ForwardIterator, class _RandomAccessIterator, class _Compare, class _IsVector>
  1991. _RandomAccessIterator
  1992. __pattern_partial_sort_copy(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last,
  1993. _RandomAccessIterator __d_first, _RandomAccessIterator __d_last, _Compare __comp,
  1994. _IsVector __is_vector, /*is_parallel=*/std::true_type)
  1995. {
  1996. if (__last == __first || __d_last == __d_first)
  1997. {
  1998. return __d_first;
  1999. }
  2000. auto __n1 = __last - __first;
  2001. auto __n2 = __d_last - __d_first;
  2002. return __internal::__except_handler([&]() {
  2003. if (__n2 >= __n1)
  2004. {
  2005. __par_backend::__parallel_stable_sort(
  2006. std::forward<_ExecutionPolicy>(__exec), __d_first, __d_first + __n1, __comp,
  2007. [__first, __d_first, __is_vector](_RandomAccessIterator __i, _RandomAccessIterator __j,
  2008. _Compare __comp) {
  2009. _ForwardIterator __i1 = __first + (__i - __d_first);
  2010. _ForwardIterator __j1 = __first + (__j - __d_first);
  2011. // 1. Copy elements from input to output
  2012. # if !_PSTL_ICC_18_OMP_SIMD_BROKEN
  2013. __internal::__brick_copy(__i1, __j1, __i, __is_vector);
  2014. # else
  2015. std::copy(__i1, __j1, __i);
  2016. # endif
  2017. // 2. Sort elements in output sequence
  2018. std::sort(__i, __j, __comp);
  2019. },
  2020. __n1);
  2021. return __d_first + __n1;
  2022. }
  2023. else
  2024. {
  2025. typedef typename std::iterator_traits<_ForwardIterator>::value_type _T1;
  2026. typedef typename std::iterator_traits<_RandomAccessIterator>::value_type _T2;
  2027. __par_backend::__buffer<_T1> __buf(__n1);
  2028. _T1* __r = __buf.get();
  2029. __par_backend::__parallel_stable_sort(std::forward<_ExecutionPolicy>(__exec), __r, __r + __n1, __comp,
  2030. [__n2, __first, __r](_T1* __i, _T1* __j, _Compare __comp) {
  2031. _ForwardIterator __it = __first + (__i - __r);
  2032. // 1. Copy elements from input to raw memory
  2033. for (_T1* __k = __i; __k != __j; ++__k, ++__it)
  2034. {
  2035. ::new (__k) _T2(*__it);
  2036. }
  2037. // 2. Sort elements in temporary __buffer
  2038. if (__n2 < __j - __i)
  2039. std::partial_sort(__i, __i + __n2, __j, __comp);
  2040. else
  2041. std::sort(__i, __j, __comp);
  2042. },
  2043. __n2);
  2044. // 3. Move elements from temporary __buffer to output
  2045. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __r, __r + __n2,
  2046. [__r, __d_first, __is_vector](_T1* __i, _T1* __j) {
  2047. __brick_move_destroy()(
  2048. __i, __j, __d_first + (__i - __r), __is_vector);
  2049. });
  2050. __par_backend::__parallel_for(
  2051. std::forward<_ExecutionPolicy>(__exec), __r + __n2, __r + __n1,
  2052. [__is_vector](_T1* __i, _T1* __j) { __brick_destroy(__i, __j, __is_vector); });
  2053. return __d_first + __n2;
  2054. }
  2055. });
  2056. }
  2057. //------------------------------------------------------------------------
  2058. // adjacent_find
  2059. //------------------------------------------------------------------------
  2060. template <class _ForwardIterator, class _BinaryPredicate>
  2061. _ForwardIterator
  2062. __brick_adjacent_find(_ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  2063. /* IsVector = */ std::true_type, bool __or_semantic) noexcept
  2064. {
  2065. return __unseq_backend::__simd_adjacent_find(__first, __last, __pred, __or_semantic);
  2066. }
  2067. template <class _ForwardIterator, class _BinaryPredicate>
  2068. _ForwardIterator
  2069. __brick_adjacent_find(_ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  2070. /* IsVector = */ std::false_type, bool) noexcept
  2071. {
  2072. return std::adjacent_find(__first, __last, __pred);
  2073. }
  2074. template <class _ExecutionPolicy, class _ForwardIterator, class _BinaryPredicate, class _IsVector>
  2075. _ForwardIterator
  2076. __pattern_adjacent_find(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _BinaryPredicate __pred,
  2077. /* is_parallel */ std::false_type, _IsVector __is_vector, bool __or_semantic) noexcept
  2078. {
  2079. return __internal::__brick_adjacent_find(__first, __last, __pred, __is_vector, __or_semantic);
  2080. }
  2081. template <class _ExecutionPolicy, class _RandomAccessIterator, class _BinaryPredicate, class _IsVector>
  2082. _RandomAccessIterator
  2083. __pattern_adjacent_find(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  2084. _BinaryPredicate __pred, /* is_parallel */ std::true_type, _IsVector __is_vector,
  2085. bool __or_semantic)
  2086. {
  2087. if (__last - __first < 2)
  2088. return __last;
  2089. return __internal::__except_handler([&]() {
  2090. return __par_backend::__parallel_reduce(
  2091. std::forward<_ExecutionPolicy>(__exec), __first, __last, __last,
  2092. [__last, __pred, __is_vector, __or_semantic](_RandomAccessIterator __begin, _RandomAccessIterator __end,
  2093. _RandomAccessIterator __value) -> _RandomAccessIterator {
  2094. // TODO: investigate performance benefits from the use of shared variable for the result,
  2095. // checking (compare_and_swap idiom) its __value at __first.
  2096. if (__or_semantic && __value < __last)
  2097. { //found
  2098. __par_backend::__cancel_execution();
  2099. return __value;
  2100. }
  2101. if (__value > __begin)
  2102. {
  2103. // modify __end to check the predicate on the boundary __values;
  2104. // TODO: to use a custom range with boundaries overlapping
  2105. // TODO: investigate what if we remove "if" below and run algorithm on range [__first, __last-1)
  2106. // then check the pair [__last-1, __last)
  2107. if (__end != __last)
  2108. ++__end;
  2109. //correct the global result iterator if the "brick" returns a local "__last"
  2110. const _RandomAccessIterator __res =
  2111. __internal::__brick_adjacent_find(__begin, __end, __pred, __is_vector, __or_semantic);
  2112. if (__res < __end)
  2113. __value = __res;
  2114. }
  2115. return __value;
  2116. },
  2117. [](_RandomAccessIterator __x, _RandomAccessIterator __y) -> _RandomAccessIterator {
  2118. return __x < __y ? __x : __y;
  2119. } //reduce a __value
  2120. );
  2121. });
  2122. }
  2123. //------------------------------------------------------------------------
  2124. // nth_element
  2125. //------------------------------------------------------------------------
  2126. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  2127. void
  2128. __pattern_nth_element(_ExecutionPolicy&&, _RandomAccessIterator __first, _RandomAccessIterator __nth,
  2129. _RandomAccessIterator __last, _Compare __comp, _IsVector,
  2130. /*is_parallel=*/std::false_type) noexcept
  2131. {
  2132. std::nth_element(__first, __nth, __last, __comp);
  2133. }
  2134. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  2135. void
  2136. __pattern_nth_element(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __nth,
  2137. _RandomAccessIterator __last, _Compare __comp, _IsVector __is_vector,
  2138. /*is_parallel=*/std::true_type) noexcept
  2139. {
  2140. if (__first == __last || __nth == __last)
  2141. {
  2142. return;
  2143. }
  2144. using std::iter_swap;
  2145. typedef typename std::iterator_traits<_RandomAccessIterator>::value_type _Tp;
  2146. _RandomAccessIterator __x;
  2147. do
  2148. {
  2149. __x = __internal::__pattern_partition(std::forward<_ExecutionPolicy>(__exec), __first + 1, __last,
  2150. [&__comp, __first](const _Tp& __x) { return __comp(__x, *__first); },
  2151. __is_vector,
  2152. /*is_parallel=*/std::true_type());
  2153. --__x;
  2154. if (__x != __first)
  2155. {
  2156. iter_swap(__first, __x);
  2157. }
  2158. // if x > nth then our new range for partition is [first, x)
  2159. if (__x - __nth > 0)
  2160. {
  2161. __last = __x;
  2162. }
  2163. // if x < nth then our new range for partition is [x, last)
  2164. else if (__x - __nth < 0)
  2165. {
  2166. // if *x == *nth then we can start new partition with x+1
  2167. if (!__comp(*__nth, *__x) && !__comp(*__x, *__nth))
  2168. {
  2169. ++__x;
  2170. }
  2171. else
  2172. {
  2173. iter_swap(__nth, __x);
  2174. }
  2175. __first = __x;
  2176. }
  2177. } while (__x != __nth);
  2178. }
  2179. //------------------------------------------------------------------------
  2180. // fill, fill_n
  2181. //------------------------------------------------------------------------
  2182. template <class _ForwardIterator, class _Tp>
  2183. void
  2184. __brick_fill(_ForwardIterator __first, _ForwardIterator __last, const _Tp& __value,
  2185. /* __is_vector = */ std::true_type) noexcept
  2186. {
  2187. __unseq_backend::__simd_fill_n(__first, __last - __first, __value);
  2188. }
  2189. template <class _ForwardIterator, class _Tp>
  2190. void
  2191. __brick_fill(_ForwardIterator __first, _ForwardIterator __last, const _Tp& __value,
  2192. /* __is_vector = */ std::false_type) noexcept
  2193. {
  2194. std::fill(__first, __last, __value);
  2195. }
  2196. template <class _ExecutionPolicy, class _ForwardIterator, class _Tp, class _IsVector>
  2197. void
  2198. __pattern_fill(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, const _Tp& __value,
  2199. /*is_parallel=*/std::false_type, _IsVector __is_vector) noexcept
  2200. {
  2201. __internal::__brick_fill(__first, __last, __value, __is_vector);
  2202. }
  2203. template <class _ExecutionPolicy, class _ForwardIterator, class _Tp, class _IsVector>
  2204. _ForwardIterator
  2205. __pattern_fill(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, const _Tp& __value,
  2206. /*is_parallel=*/std::true_type, _IsVector __is_vector)
  2207. {
  2208. return __internal::__except_handler([&__exec, __first, __last, &__value, __is_vector]() {
  2209. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  2210. [&__value, __is_vector](_ForwardIterator __begin, _ForwardIterator __end) {
  2211. __internal::__brick_fill(__begin, __end, __value, __is_vector);
  2212. });
  2213. return __last;
  2214. });
  2215. }
  2216. template <class _OutputIterator, class _Size, class _Tp>
  2217. _OutputIterator
  2218. __brick_fill_n(_OutputIterator __first, _Size __count, const _Tp& __value, /* __is_vector = */ std::true_type) noexcept
  2219. {
  2220. return __unseq_backend::__simd_fill_n(__first, __count, __value);
  2221. }
  2222. template <class _OutputIterator, class _Size, class _Tp>
  2223. _OutputIterator
  2224. __brick_fill_n(_OutputIterator __first, _Size __count, const _Tp& __value, /* __is_vector = */ std::false_type) noexcept
  2225. {
  2226. return std::fill_n(__first, __count, __value);
  2227. }
  2228. template <class _ExecutionPolicy, class _OutputIterator, class _Size, class _Tp, class _IsVector>
  2229. _OutputIterator
  2230. __pattern_fill_n(_ExecutionPolicy&&, _OutputIterator __first, _Size __count, const _Tp& __value,
  2231. /*is_parallel=*/std::false_type, _IsVector __is_vector) noexcept
  2232. {
  2233. return __internal::__brick_fill_n(__first, __count, __value, __is_vector);
  2234. }
  2235. template <class _ExecutionPolicy, class _OutputIterator, class _Size, class _Tp, class _IsVector>
  2236. _OutputIterator
  2237. __pattern_fill_n(_ExecutionPolicy&& __exec, _OutputIterator __first, _Size __count, const _Tp& __value,
  2238. /*is_parallel=*/std::true_type, _IsVector __is_vector)
  2239. {
  2240. return __internal::__pattern_fill(std::forward<_ExecutionPolicy>(__exec), __first, __first + __count, __value,
  2241. std::true_type(), __is_vector);
  2242. }
  2243. //------------------------------------------------------------------------
  2244. // generate, generate_n
  2245. //------------------------------------------------------------------------
  2246. template <class _RandomAccessIterator, class _Generator>
  2247. void
  2248. __brick_generate(_RandomAccessIterator __first, _RandomAccessIterator __last, _Generator __g,
  2249. /* is_vector = */ std::true_type) noexcept
  2250. {
  2251. __unseq_backend::__simd_generate_n(__first, __last - __first, __g);
  2252. }
  2253. template <class _ForwardIterator, class _Generator>
  2254. void
  2255. __brick_generate(_ForwardIterator __first, _ForwardIterator __last, _Generator __g,
  2256. /* is_vector = */ std::false_type) noexcept
  2257. {
  2258. std::generate(__first, __last, __g);
  2259. }
  2260. template <class _ExecutionPolicy, class _ForwardIterator, class _Generator, class _IsVector>
  2261. void
  2262. __pattern_generate(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Generator __g,
  2263. /*is_parallel=*/std::false_type, _IsVector __is_vector) noexcept
  2264. {
  2265. __internal::__brick_generate(__first, __last, __g, __is_vector);
  2266. }
  2267. template <class _ExecutionPolicy, class _ForwardIterator, class _Generator, class _IsVector>
  2268. _ForwardIterator
  2269. __pattern_generate(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Generator __g,
  2270. /*is_parallel=*/std::true_type, _IsVector __is_vector)
  2271. {
  2272. return __internal::__except_handler([&]() {
  2273. __par_backend::__parallel_for(std::forward<_ExecutionPolicy>(__exec), __first, __last,
  2274. [__g, __is_vector](_ForwardIterator __begin, _ForwardIterator __end) {
  2275. __internal::__brick_generate(__begin, __end, __g, __is_vector);
  2276. });
  2277. return __last;
  2278. });
  2279. }
  2280. template <class OutputIterator, class Size, class _Generator>
  2281. OutputIterator
  2282. __brick_generate_n(OutputIterator __first, Size __count, _Generator __g, /* is_vector = */ std::true_type) noexcept
  2283. {
  2284. return __unseq_backend::__simd_generate_n(__first, __count, __g);
  2285. }
  2286. template <class OutputIterator, class Size, class _Generator>
  2287. OutputIterator
  2288. __brick_generate_n(OutputIterator __first, Size __count, _Generator __g, /* is_vector = */ std::false_type) noexcept
  2289. {
  2290. return std::generate_n(__first, __count, __g);
  2291. }
  2292. template <class _ExecutionPolicy, class _OutputIterator, class _Size, class _Generator, class _IsVector>
  2293. _OutputIterator
  2294. __pattern_generate_n(_ExecutionPolicy&&, _OutputIterator __first, _Size __count, _Generator __g,
  2295. /*is_parallel=*/std::false_type, _IsVector __is_vector) noexcept
  2296. {
  2297. return __internal::__brick_generate_n(__first, __count, __g, __is_vector);
  2298. }
  2299. template <class _ExecutionPolicy, class _OutputIterator, class _Size, class _Generator, class _IsVector>
  2300. _OutputIterator
  2301. __pattern_generate_n(_ExecutionPolicy&& __exec, _OutputIterator __first, _Size __count, _Generator __g,
  2302. /*is_parallel=*/std::true_type, _IsVector __is_vector)
  2303. {
  2304. static_assert(__is_random_access_iterator<_OutputIterator>::value,
  2305. "Pattern-brick error. Should be a random access iterator.");
  2306. return __internal::__pattern_generate(std::forward<_ExecutionPolicy>(__exec), __first, __first + __count, __g,
  2307. std::true_type(), __is_vector);
  2308. }
  2309. //------------------------------------------------------------------------
  2310. // remove
  2311. //------------------------------------------------------------------------
  2312. template <class _ForwardIterator, class _UnaryPredicate>
  2313. _ForwardIterator
  2314. __brick_remove_if(_ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  2315. /* __is_vector = */ std::false_type) noexcept
  2316. {
  2317. return std::remove_if(__first, __last, __pred);
  2318. }
  2319. template <class _RandomAccessIterator, class _UnaryPredicate>
  2320. _RandomAccessIterator
  2321. __brick_remove_if(_RandomAccessIterator __first, _RandomAccessIterator __last, _UnaryPredicate __pred,
  2322. /* __is_vector = */ std::true_type) noexcept
  2323. {
  2324. #if _PSTL_MONOTONIC_PRESENT
  2325. return __unseq_backend::__simd_remove_if(__first, __last - __first, __pred);
  2326. #else
  2327. return std::remove_if(__first, __last, __pred);
  2328. #endif
  2329. }
  2330. template <class _ExecutionPolicy, class _ForwardIterator, class _UnaryPredicate, class _IsVector>
  2331. _ForwardIterator
  2332. __pattern_remove_if(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _UnaryPredicate __pred,
  2333. _IsVector __is_vector, /*is_parallel*/ std::false_type) noexcept
  2334. {
  2335. return __internal::__brick_remove_if(__first, __last, __pred, __is_vector);
  2336. }
  2337. template <class _ExecutionPolicy, class _ForwardIterator, class _UnaryPredicate, class _IsVector>
  2338. _ForwardIterator
  2339. __pattern_remove_if(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last,
  2340. _UnaryPredicate __pred, _IsVector __is_vector, /*is_parallel*/ std::true_type) noexcept
  2341. {
  2342. typedef typename std::iterator_traits<_ForwardIterator>::reference _ReferenceType;
  2343. if (__first == __last || __first + 1 == __last)
  2344. {
  2345. // Trivial sequence - use serial algorithm
  2346. return __internal::__brick_remove_if(__first, __last, __pred, __is_vector);
  2347. }
  2348. return __internal::__remove_elements(
  2349. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  2350. [&__pred, __is_vector](bool* __b, bool* __e, _ForwardIterator __it) {
  2351. __internal::__brick_walk2(__b, __e, __it, [&__pred](bool& __x, _ReferenceType __y) { __x = !__pred(__y); },
  2352. __is_vector);
  2353. },
  2354. __is_vector);
  2355. }
  2356. //------------------------------------------------------------------------
  2357. // merge
  2358. //------------------------------------------------------------------------
  2359. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2360. _OutputIterator
  2361. __brick_merge(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2362. _ForwardIterator2 __last2, _OutputIterator __d_first, _Compare __comp,
  2363. /* __is_vector = */ std::false_type) noexcept
  2364. {
  2365. return std::merge(__first1, __last1, __first2, __last2, __d_first, __comp);
  2366. }
  2367. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2368. _OutputIterator
  2369. __brick_merge(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2370. _ForwardIterator2 __last2, _OutputIterator __d_first, _Compare __comp,
  2371. /* __is_vector = */ std::true_type) noexcept
  2372. {
  2373. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  2374. return std::merge(__first1, __last1, __first2, __last2, __d_first, __comp);
  2375. }
  2376. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2377. class _Compare, class _IsVector>
  2378. _OutputIterator
  2379. __pattern_merge(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2380. _ForwardIterator2 __last2, _OutputIterator __d_first, _Compare __comp, _IsVector __is_vector,
  2381. /* is_parallel = */ std::false_type) noexcept
  2382. {
  2383. return __internal::__brick_merge(__first1, __last1, __first2, __last2, __d_first, __comp, __is_vector);
  2384. }
  2385. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _RandomAccessIterator2, class _OutputIterator,
  2386. class _Compare, class _IsVector>
  2387. _OutputIterator
  2388. __pattern_merge(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1,
  2389. _RandomAccessIterator2 __first2, _RandomAccessIterator2 __last2, _OutputIterator __d_first,
  2390. _Compare __comp, _IsVector __is_vector, /* is_parallel = */ std::true_type)
  2391. {
  2392. __par_backend::__parallel_merge(
  2393. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __first2, __last2, __d_first, __comp,
  2394. [__is_vector](_RandomAccessIterator1 __f1, _RandomAccessIterator1 __l1, _RandomAccessIterator2 __f2,
  2395. _RandomAccessIterator2 __l2, _OutputIterator __f3, _Compare __comp) {
  2396. return __internal::__brick_merge(__f1, __l1, __f2, __l2, __f3, __comp, __is_vector);
  2397. });
  2398. return __d_first + (__last1 - __first1) + (__last2 - __first2);
  2399. }
  2400. //------------------------------------------------------------------------
  2401. // inplace_merge
  2402. //------------------------------------------------------------------------
  2403. template <class _BidirectionalIterator, class _Compare>
  2404. void
  2405. __brick_inplace_merge(_BidirectionalIterator __first, _BidirectionalIterator __middle, _BidirectionalIterator __last,
  2406. _Compare __comp, /* __is_vector = */ std::false_type) noexcept
  2407. {
  2408. std::inplace_merge(__first, __middle, __last, __comp);
  2409. }
  2410. template <class _BidirectionalIterator, class _Compare>
  2411. void
  2412. __brick_inplace_merge(_BidirectionalIterator __first, _BidirectionalIterator __middle, _BidirectionalIterator __last,
  2413. _Compare __comp, /* __is_vector = */ std::true_type) noexcept
  2414. {
  2415. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial")
  2416. std::inplace_merge(__first, __middle, __last, __comp);
  2417. }
  2418. template <class _ExecutionPolicy, class _BidirectionalIterator, class _Compare, class _IsVector>
  2419. void
  2420. __pattern_inplace_merge(_ExecutionPolicy&&, _BidirectionalIterator __first, _BidirectionalIterator __middle,
  2421. _BidirectionalIterator __last, _Compare __comp, _IsVector __is_vector,
  2422. /* is_parallel = */ std::false_type) noexcept
  2423. {
  2424. __internal::__brick_inplace_merge(__first, __middle, __last, __comp, __is_vector);
  2425. }
  2426. template <class _ExecutionPolicy, class _BidirectionalIterator, class _Compare, class _IsVector>
  2427. void
  2428. __pattern_inplace_merge(_ExecutionPolicy&& __exec, _BidirectionalIterator __first, _BidirectionalIterator __middle,
  2429. _BidirectionalIterator __last, _Compare __comp, _IsVector __is_vector,
  2430. /*is_parallel=*/std::true_type)
  2431. {
  2432. if (__first == __last || __first == __middle || __middle == __last)
  2433. {
  2434. return;
  2435. }
  2436. typedef typename std::iterator_traits<_BidirectionalIterator>::value_type _Tp;
  2437. auto __n = __last - __first;
  2438. __par_backend::__buffer<_Tp> __buf(__n);
  2439. _Tp* __r = __buf.get();
  2440. __internal::__except_handler([&]() {
  2441. auto __move_values = [](_BidirectionalIterator __x, _Tp* __z) {
  2442. __internal::__invoke_if_else(std::is_trivial<_Tp>(), [&]() { *__z = std::move(*__x); },
  2443. [&]() { ::new (std::addressof(*__z)) _Tp(std::move(*__x)); });
  2444. };
  2445. auto __move_sequences = [](_BidirectionalIterator __first1, _BidirectionalIterator __last1, _Tp* __first2) {
  2446. return __internal::__brick_uninitialized_move(__first1, __last1, __first2, _IsVector());
  2447. };
  2448. __par_backend::__parallel_merge(
  2449. std::forward<_ExecutionPolicy>(__exec), __first, __middle, __middle, __last, __r, __comp,
  2450. [__n, __move_values, __move_sequences](_BidirectionalIterator __f1, _BidirectionalIterator __l1,
  2451. _BidirectionalIterator __f2, _BidirectionalIterator __l2, _Tp* __f3,
  2452. _Compare __comp) {
  2453. (__utils::__serial_move_merge(__n))(__f1, __l1, __f2, __l2, __f3, __comp, __move_values, __move_values,
  2454. __move_sequences, __move_sequences);
  2455. return __f3 + (__l1 - __f1) + (__l2 - __f2);
  2456. });
  2457. __par_backend::__parallel_for(
  2458. std::forward<_ExecutionPolicy>(__exec), __r, __r + __n, [__r, __first, __is_vector](_Tp* __i, _Tp* __j) {
  2459. __brick_move_destroy()(__i, __j, __first + (__i - __r), __is_vector);
  2460. });
  2461. });
  2462. }
  2463. //------------------------------------------------------------------------
  2464. // includes
  2465. //------------------------------------------------------------------------
  2466. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Compare, class _IsVector>
  2467. bool
  2468. __pattern_includes(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2469. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _Compare __comp, _IsVector,
  2470. /*is_parallel=*/std::false_type) noexcept
  2471. {
  2472. return std::includes(__first1, __last1, __first2, __last2, __comp);
  2473. }
  2474. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Compare, class _IsVector>
  2475. bool
  2476. __pattern_includes(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2477. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _Compare __comp, _IsVector,
  2478. /*is_parallel=*/std::true_type)
  2479. {
  2480. if (__first2 >= __last2)
  2481. return true;
  2482. if (__first1 >= __last1 || __comp(*__first2, *__first1) || __comp(*(__last1 - 1), *(__last2 - 1)))
  2483. return false;
  2484. __first1 = std::lower_bound(__first1, __last1, *__first2, __comp);
  2485. if (__first1 == __last1)
  2486. return false;
  2487. if (__last2 - __first2 == 1)
  2488. return !__comp(*__first1, *__first2) && !__comp(*__first2, *__first1);
  2489. return __internal::__except_handler([&]() {
  2490. return !__internal::__parallel_or(
  2491. std::forward<_ExecutionPolicy>(__exec), __first2, __last2,
  2492. [__first1, __last1, __first2, __last2, &__comp](_ForwardIterator2 __i, _ForwardIterator2 __j) {
  2493. _PSTL_ASSERT(__j > __i);
  2494. //assert(__j - __i > 1);
  2495. //1. moving boundaries to "consume" subsequence of equal elements
  2496. auto __is_equal = [&__comp](_ForwardIterator2 __a, _ForwardIterator2 __b) -> bool {
  2497. return !__comp(*__a, *__b) && !__comp(*__b, *__a);
  2498. };
  2499. //1.1 left bound, case "aaa[aaaxyz...]" - searching "x"
  2500. if (__i > __first2 && __is_equal(__i, __i - 1))
  2501. {
  2502. //whole subrange continues to content equal elements - return "no op"
  2503. if (__is_equal(__i, __j - 1))
  2504. return false;
  2505. __i = std::upper_bound(__i, __last2, *__i, __comp);
  2506. }
  2507. //1.2 right bound, case "[...aaa]aaaxyz" - searching "x"
  2508. if (__j < __last2 && __is_equal(__j - 1, __j))
  2509. __j = std::upper_bound(__j, __last2, *__j, __comp);
  2510. //2. testing is __a subsequence of the second range included into the first range
  2511. auto __b = std::lower_bound(__first1, __last1, *__i, __comp);
  2512. _PSTL_ASSERT(!__comp(*(__last1 - 1), *__b));
  2513. _PSTL_ASSERT(!__comp(*(__j - 1), *__i));
  2514. return !std::includes(__b, __last1, __i, __j, __comp);
  2515. });
  2516. });
  2517. }
  2518. constexpr auto __set_algo_cut_off = 1000;
  2519. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2520. class _Compare, class _IsVector, class _SizeFunction, class _SetOP>
  2521. _OutputIterator
  2522. __parallel_set_op(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2523. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2524. _SizeFunction __size_func, _SetOP __set_op, _IsVector __is_vector)
  2525. {
  2526. typedef typename std::iterator_traits<_ForwardIterator1>::difference_type _DifferenceType;
  2527. typedef typename std::iterator_traits<_OutputIterator>::value_type _Tp;
  2528. struct _SetRange
  2529. {
  2530. _DifferenceType __pos, __len, __buf_pos;
  2531. bool
  2532. empty() const
  2533. {
  2534. return __len == 0;
  2535. }
  2536. };
  2537. const _DifferenceType __n1 = __last1 - __first1;
  2538. const _DifferenceType __n2 = __last2 - __first2;
  2539. __par_backend::__buffer<_Tp> __buf(__size_func(__n1, __n2));
  2540. return __internal::__except_handler([&__exec, __n1, __first1, __last1, __first2, __last2, __result, __is_vector,
  2541. __comp, __size_func, __set_op, &__buf]() {
  2542. auto __buffer = __buf.get();
  2543. _DifferenceType __m{};
  2544. auto __scan = [=](_DifferenceType, _DifferenceType, const _SetRange& __s) { // Scan
  2545. if (!__s.empty())
  2546. __brick_move_destroy()(__buffer + __s.__buf_pos,
  2547. __buffer + (__s.__buf_pos + __s.__len), __result + __s.__pos,
  2548. __is_vector);
  2549. };
  2550. __par_backend::__parallel_strict_scan(
  2551. std::forward<_ExecutionPolicy>(__exec), __n1, _SetRange{0, 0, 0}, //-1, 0},
  2552. [=](_DifferenceType __i, _DifferenceType __len) { // Reduce
  2553. //[__b; __e) - a subrange of the first sequence, to reduce
  2554. _ForwardIterator1 __b = __first1 + __i, __e = __first1 + (__i + __len);
  2555. //try searching for the first element which not equal to *__b
  2556. if (__b != __first1)
  2557. __b = std::upper_bound(__b, __last1, *__b, __comp);
  2558. //try searching for the first element which not equal to *__e
  2559. if (__e != __last1)
  2560. __e = std::upper_bound(__e, __last1, *__e, __comp);
  2561. //check is [__b; __e) empty
  2562. if (__e - __b < 1)
  2563. {
  2564. _ForwardIterator2 __bb = __last2;
  2565. if (__b != __last1)
  2566. __bb = std::lower_bound(__first2, __last2, *__b, __comp);
  2567. const _DifferenceType __buf_pos = __size_func((__b - __first1), (__bb - __first2));
  2568. return _SetRange{0, 0, __buf_pos};
  2569. }
  2570. //try searching for "corresponding" subrange [__bb; __ee) in the second sequence
  2571. _ForwardIterator2 __bb = __first2;
  2572. if (__b != __first1)
  2573. __bb = std::lower_bound(__first2, __last2, *__b, __comp);
  2574. _ForwardIterator2 __ee = __last2;
  2575. if (__e != __last1)
  2576. __ee = std::lower_bound(__bb, __last2, *__e, __comp);
  2577. const _DifferenceType __buf_pos = __size_func((__b - __first1), (__bb - __first2));
  2578. auto __buffer_b = __buffer + __buf_pos;
  2579. auto __res = __set_op(__b, __e, __bb, __ee, __buffer_b, __comp);
  2580. return _SetRange{0, __res - __buffer_b, __buf_pos};
  2581. },
  2582. [](const _SetRange& __a, const _SetRange& __b) { // Combine
  2583. if (__b.__buf_pos > __a.__buf_pos || ((__b.__buf_pos == __a.__buf_pos) && !__b.empty()))
  2584. return _SetRange{__a.__pos + __a.__len + __b.__pos, __b.__len, __b.__buf_pos};
  2585. return _SetRange{__b.__pos + __b.__len + __a.__pos, __a.__len, __a.__buf_pos};
  2586. },
  2587. __scan, // Scan
  2588. [&__m, &__scan](const _SetRange& __total) { // Apex
  2589. //final scan
  2590. __scan(0, 0, __total);
  2591. __m = __total.__pos + __total.__len;
  2592. });
  2593. return __result + __m;
  2594. });
  2595. }
  2596. //a shared parallel pattern for '__pattern_set_union' and '__pattern_set_symmetric_difference'
  2597. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2598. class _Compare, class _SetUnionOp, class _IsVector>
  2599. _OutputIterator
  2600. __parallel_set_union_op(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2601. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2602. _Compare __comp, _SetUnionOp __set_union_op, _IsVector __is_vector)
  2603. {
  2604. typedef typename std::iterator_traits<_ForwardIterator1>::difference_type _DifferenceType;
  2605. const auto __n1 = __last1 - __first1;
  2606. const auto __n2 = __last2 - __first2;
  2607. auto __copy_range1 = [__is_vector](_ForwardIterator1 __begin, _ForwardIterator1 __end, _OutputIterator __res) {
  2608. return __internal::__brick_copy(__begin, __end, __res, __is_vector);
  2609. };
  2610. auto __copy_range2 = [__is_vector](_ForwardIterator2 __begin, _ForwardIterator2 __end, _OutputIterator __res) {
  2611. return __internal::__brick_copy(__begin, __end, __res, __is_vector);
  2612. };
  2613. // {1} {}: parallel copying just first sequence
  2614. if (__n2 == 0)
  2615. return __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __result,
  2616. __copy_range1, std::true_type());
  2617. // {} {2}: parallel copying justmake second sequence
  2618. if (__n1 == 0)
  2619. return __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first2, __last2, __result,
  2620. __copy_range2, std::true_type());
  2621. // testing whether the sequences are intersected
  2622. _ForwardIterator1 __left_bound_seq_1 = std::lower_bound(__first1, __last1, *__first2, __comp);
  2623. if (__left_bound_seq_1 == __last1)
  2624. {
  2625. //{1} < {2}: seq2 is wholly greater than seq1, so, do parallel copying seq1 and seq2
  2626. __par_backend::__parallel_invoke(
  2627. std::forward<_ExecutionPolicy>(__exec),
  2628. [=] {
  2629. __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __result,
  2630. __copy_range1, std::true_type());
  2631. },
  2632. [=] {
  2633. __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first2, __last2,
  2634. __result + __n1, __copy_range2, std::true_type());
  2635. });
  2636. return __result + __n1 + __n2;
  2637. }
  2638. // testing whether the sequences are intersected
  2639. _ForwardIterator2 __left_bound_seq_2 = std::lower_bound(__first2, __last2, *__first1, __comp);
  2640. if (__left_bound_seq_2 == __last2)
  2641. {
  2642. //{2} < {1}: seq2 is wholly greater than seq1, so, do parallel copying seq1 and seq2
  2643. __par_backend::__parallel_invoke(
  2644. std::forward<_ExecutionPolicy>(__exec),
  2645. [=] {
  2646. __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first2, __last2, __result,
  2647. __copy_range2, std::true_type());
  2648. },
  2649. [=] {
  2650. __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first1, __last1,
  2651. __result + __n2, __copy_range1, std::true_type());
  2652. });
  2653. return __result + __n1 + __n2;
  2654. }
  2655. const auto __m1 = __left_bound_seq_1 - __first1;
  2656. if (__m1 > __set_algo_cut_off)
  2657. {
  2658. auto __res_or = __result;
  2659. __result += __m1; //we know proper offset due to [first1; left_bound_seq_1) < [first2; last2)
  2660. __par_backend::__parallel_invoke(
  2661. std::forward<_ExecutionPolicy>(__exec),
  2662. //do parallel copying of [first1; left_bound_seq_1)
  2663. [=] {
  2664. __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first1, __left_bound_seq_1,
  2665. __res_or, __copy_range1, std::true_type());
  2666. },
  2667. [=, &__result] {
  2668. __result = __internal::__parallel_set_op(
  2669. std::forward<_ExecutionPolicy>(__exec), __left_bound_seq_1, __last1, __first2, __last2, __result,
  2670. __comp, [](_DifferenceType __n, _DifferenceType __m) { return __n + __m; }, __set_union_op,
  2671. __is_vector);
  2672. });
  2673. return __result;
  2674. }
  2675. const auto __m2 = __left_bound_seq_2 - __first2;
  2676. _PSTL_ASSERT(__m1 == 0 || __m2 == 0);
  2677. if (__m2 > __set_algo_cut_off)
  2678. {
  2679. auto __res_or = __result;
  2680. __result += __m2; //we know proper offset due to [first2; left_bound_seq_2) < [first1; last1)
  2681. __par_backend::__parallel_invoke(
  2682. std::forward<_ExecutionPolicy>(__exec),
  2683. //do parallel copying of [first2; left_bound_seq_2)
  2684. [=] {
  2685. __internal::__pattern_walk2_brick(std::forward<_ExecutionPolicy>(__exec), __first2, __left_bound_seq_2,
  2686. __res_or, __copy_range2, std::true_type());
  2687. },
  2688. [=, &__result] {
  2689. __result = __internal::__parallel_set_op(
  2690. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __left_bound_seq_2, __last2, __result,
  2691. __comp, [](_DifferenceType __n, _DifferenceType __m) { return __n + __m; }, __set_union_op,
  2692. __is_vector);
  2693. });
  2694. return __result;
  2695. }
  2696. return __internal::__parallel_set_op(
  2697. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __first2, __last2, __result, __comp,
  2698. [](_DifferenceType __n, _DifferenceType __m) { return __n + __m; }, __set_union_op, __is_vector);
  2699. }
  2700. //------------------------------------------------------------------------
  2701. // set_union
  2702. //------------------------------------------------------------------------
  2703. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2704. _OutputIterator
  2705. __brick_set_union(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2706. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2707. /*__is_vector=*/std::false_type) noexcept
  2708. {
  2709. return std::set_union(__first1, __last1, __first2, __last2, __result, __comp);
  2710. }
  2711. template <typename _IsVector>
  2712. struct __BrickCopyConstruct
  2713. {
  2714. template <typename _ForwardIterator, typename _OutputIterator>
  2715. _OutputIterator
  2716. operator()(_ForwardIterator __first, _ForwardIterator __last, _OutputIterator __result)
  2717. {
  2718. return __brick_uninitialized_copy(__first, __last, __result, _IsVector());
  2719. }
  2720. };
  2721. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2722. _OutputIterator
  2723. __brick_set_union(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2724. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2725. /*__is_vector=*/std::true_type) noexcept
  2726. {
  2727. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  2728. return std::set_union(__first1, __last1, __first2, __last2, __result, __comp);
  2729. }
  2730. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2731. class _Compare, class _IsVector>
  2732. _OutputIterator
  2733. __pattern_set_union(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2734. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2735. _IsVector __is_vector,
  2736. /*is_parallel=*/std::false_type) noexcept
  2737. {
  2738. return __internal::__brick_set_union(__first1, __last1, __first2, __last2, __result, __comp, __is_vector);
  2739. }
  2740. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2741. class _Compare, class _IsVector>
  2742. _OutputIterator
  2743. __pattern_set_union(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2744. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2745. _IsVector __is_vector, /*__is_parallel=*/std::true_type)
  2746. {
  2747. const auto __n1 = __last1 - __first1;
  2748. const auto __n2 = __last2 - __first2;
  2749. // use serial algorithm
  2750. if (__n1 + __n2 <= __set_algo_cut_off)
  2751. return std::set_union(__first1, __last1, __first2, __last2, __result, __comp);
  2752. typedef typename std::iterator_traits<_OutputIterator>::value_type _Tp;
  2753. return __parallel_set_union_op(
  2754. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __first2, __last2, __result, __comp,
  2755. [](_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2, _ForwardIterator2 __last2,
  2756. _Tp* __result, _Compare __comp) {
  2757. return __pstl::__utils::__set_union_construct(__first1, __last1, __first2, __last2, __result, __comp,
  2758. __BrickCopyConstruct<_IsVector>());
  2759. },
  2760. __is_vector);
  2761. }
  2762. //------------------------------------------------------------------------
  2763. // set_intersection
  2764. //------------------------------------------------------------------------
  2765. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2766. _OutputIterator
  2767. __brick_set_intersection(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2768. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2769. /*__is_vector=*/std::false_type) noexcept
  2770. {
  2771. return std::set_intersection(__first1, __last1, __first2, __last2, __result, __comp);
  2772. }
  2773. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2774. _OutputIterator
  2775. __brick_set_intersection(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2776. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2777. /*__is_vector=*/std::true_type) noexcept
  2778. {
  2779. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  2780. return std::set_intersection(__first1, __last1, __first2, __last2, __result, __comp);
  2781. }
  2782. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2783. class _Compare, class _IsVector>
  2784. _OutputIterator
  2785. __pattern_set_intersection(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2786. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2787. _Compare __comp, _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  2788. {
  2789. return __internal::__brick_set_intersection(__first1, __last1, __first2, __last2, __result, __comp, __is_vector);
  2790. }
  2791. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2792. class _Compare, class _IsVector>
  2793. _OutputIterator
  2794. __pattern_set_intersection(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2795. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2796. _Compare __comp, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  2797. {
  2798. typedef typename std::iterator_traits<_OutputIterator>::value_type _Tp;
  2799. typedef typename std::iterator_traits<_ForwardIterator1>::difference_type _DifferenceType;
  2800. const auto __n1 = __last1 - __first1;
  2801. const auto __n2 = __last2 - __first2;
  2802. // intersection is empty
  2803. if (__n1 == 0 || __n2 == 0)
  2804. return __result;
  2805. // testing whether the sequences are intersected
  2806. _ForwardIterator1 __left_bound_seq_1 = std::lower_bound(__first1, __last1, *__first2, __comp);
  2807. //{1} < {2}: seq 2 is wholly greater than seq 1, so, the intersection is empty
  2808. if (__left_bound_seq_1 == __last1)
  2809. return __result;
  2810. // testing whether the sequences are intersected
  2811. _ForwardIterator2 __left_bound_seq_2 = std::lower_bound(__first2, __last2, *__first1, __comp);
  2812. //{2} < {1}: seq 1 is wholly greater than seq 2, so, the intersection is empty
  2813. if (__left_bound_seq_2 == __last2)
  2814. return __result;
  2815. const auto __m1 = __last1 - __left_bound_seq_1 + __n2;
  2816. if (__m1 > __set_algo_cut_off)
  2817. {
  2818. //we know proper offset due to [first1; left_bound_seq_1) < [first2; last2)
  2819. return __internal::__parallel_set_op(
  2820. std::forward<_ExecutionPolicy>(__exec), __left_bound_seq_1, __last1, __first2, __last2, __result, __comp,
  2821. [](_DifferenceType __n, _DifferenceType __m) { return std::min(__n, __m); },
  2822. [](_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2823. _ForwardIterator2 __last2, _Tp* __result, _Compare __comp) {
  2824. return __pstl::__utils::__set_intersection_construct(__first1, __last1, __first2, __last2, __result,
  2825. __comp);
  2826. },
  2827. __is_vector);
  2828. }
  2829. const auto __m2 = __last2 - __left_bound_seq_2 + __n1;
  2830. if (__m2 > __set_algo_cut_off)
  2831. {
  2832. //we know proper offset due to [first2; left_bound_seq_2) < [first1; last1)
  2833. __result = __internal::__parallel_set_op(
  2834. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __left_bound_seq_2, __last2, __result, __comp,
  2835. [](_DifferenceType __n, _DifferenceType __m) { return std::min(__n, __m); },
  2836. [](_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2837. _ForwardIterator2 __last2, _Tp* __result, _Compare __comp) {
  2838. return __pstl::__utils::__set_intersection_construct(__first2, __last2, __first1, __last1, __result,
  2839. __comp);
  2840. },
  2841. __is_vector);
  2842. return __result;
  2843. }
  2844. // [left_bound_seq_1; last1) and [left_bound_seq_2; last2) - use serial algorithm
  2845. return std::set_intersection(__left_bound_seq_1, __last1, __left_bound_seq_2, __last2, __result, __comp);
  2846. }
  2847. //------------------------------------------------------------------------
  2848. // set_difference
  2849. //------------------------------------------------------------------------
  2850. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2851. _OutputIterator
  2852. __brick_set_difference(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2853. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2854. /*__is_vector=*/std::false_type) noexcept
  2855. {
  2856. return std::set_difference(__first1, __last1, __first2, __last2, __result, __comp);
  2857. }
  2858. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2859. _OutputIterator
  2860. __brick_set_difference(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2861. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2862. /*__is_vector=*/std::true_type) noexcept
  2863. {
  2864. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  2865. return std::set_difference(__first1, __last1, __first2, __last2, __result, __comp);
  2866. }
  2867. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2868. class _Compare, class _IsVector>
  2869. _OutputIterator
  2870. __pattern_set_difference(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2871. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2872. _Compare __comp, _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  2873. {
  2874. return __internal::__brick_set_difference(__first1, __last1, __first2, __last2, __result, __comp, __is_vector);
  2875. }
  2876. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2877. class _Compare, class _IsVector>
  2878. _OutputIterator
  2879. __pattern_set_difference(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2880. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2881. _Compare __comp, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  2882. {
  2883. typedef typename std::iterator_traits<_OutputIterator>::value_type _Tp;
  2884. typedef typename std::iterator_traits<_ForwardIterator1>::difference_type _DifferenceType;
  2885. const auto __n1 = __last1 - __first1;
  2886. const auto __n2 = __last2 - __first2;
  2887. // {} \ {2}: the difference is empty
  2888. if (__n1 == 0)
  2889. return __result;
  2890. // {1} \ {}: parallel copying just first sequence
  2891. if (__n2 == 0)
  2892. return __internal::__pattern_walk2_brick(
  2893. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __result,
  2894. [__is_vector](_ForwardIterator1 __begin, _ForwardIterator1 __end, _OutputIterator __res) {
  2895. return __internal::__brick_copy(__begin, __end, __res, __is_vector);
  2896. },
  2897. std::true_type());
  2898. // testing whether the sequences are intersected
  2899. _ForwardIterator1 __left_bound_seq_1 = std::lower_bound(__first1, __last1, *__first2, __comp);
  2900. //{1} < {2}: seq 2 is wholly greater than seq 1, so, parallel copying just first sequence
  2901. if (__left_bound_seq_1 == __last1)
  2902. return __internal::__pattern_walk2_brick(
  2903. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __result,
  2904. [__is_vector](_ForwardIterator1 __begin, _ForwardIterator1 __end, _OutputIterator __res) {
  2905. return __internal::__brick_copy(__begin, __end, __res, __is_vector);
  2906. },
  2907. std::true_type());
  2908. // testing whether the sequences are intersected
  2909. _ForwardIterator2 __left_bound_seq_2 = std::lower_bound(__first2, __last2, *__first1, __comp);
  2910. //{2} < {1}: seq 1 is wholly greater than seq 2, so, parallel copying just first sequence
  2911. if (__left_bound_seq_2 == __last2)
  2912. return __internal::__pattern_walk2_brick(
  2913. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __result,
  2914. [__is_vector](_ForwardIterator1 __begin, _ForwardIterator1 __end, _OutputIterator __res) {
  2915. return __internal::__brick_copy(__begin, __end, __res, __is_vector);
  2916. },
  2917. std::true_type());
  2918. if (__n1 + __n2 > __set_algo_cut_off)
  2919. return __parallel_set_op(std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __first2, __last2, __result,
  2920. __comp, [](_DifferenceType __n, _DifferenceType) { return __n; },
  2921. [](_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2922. _ForwardIterator2 __last2, _Tp* __result, _Compare __comp) {
  2923. return __pstl::__utils::__set_difference_construct(
  2924. __first1, __last1, __first2, __last2, __result, __comp,
  2925. __BrickCopyConstruct<_IsVector>());
  2926. },
  2927. __is_vector);
  2928. // use serial algorithm
  2929. return std::set_difference(__first1, __last1, __first2, __last2, __result, __comp);
  2930. }
  2931. //------------------------------------------------------------------------
  2932. // set_symmetric_difference
  2933. //------------------------------------------------------------------------
  2934. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2935. _OutputIterator
  2936. __brick_set_symmetric_difference(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2937. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2938. /*__is_vector=*/std::false_type) noexcept
  2939. {
  2940. return std::set_symmetric_difference(__first1, __last1, __first2, __last2, __result, __comp);
  2941. }
  2942. template <class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator, class _Compare>
  2943. _OutputIterator
  2944. __brick_set_symmetric_difference(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  2945. _ForwardIterator2 __last2, _OutputIterator __result, _Compare __comp,
  2946. /*__is_vector=*/std::true_type) noexcept
  2947. {
  2948. _PSTL_PRAGMA_MESSAGE("Vectorized algorithm unimplemented, redirected to serial");
  2949. return std::set_symmetric_difference(__first1, __last1, __first2, __last2, __result, __comp);
  2950. }
  2951. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2952. class _Compare, class _IsVector>
  2953. _OutputIterator
  2954. __pattern_set_symmetric_difference(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2955. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2956. _Compare __comp, _IsVector __is_vector, /*is_parallel=*/std::false_type) noexcept
  2957. {
  2958. return __internal::__brick_set_symmetric_difference(__first1, __last1, __first2, __last2, __result, __comp,
  2959. __is_vector);
  2960. }
  2961. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _OutputIterator,
  2962. class _Compare, class _IsVector>
  2963. _OutputIterator
  2964. __pattern_set_symmetric_difference(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  2965. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _OutputIterator __result,
  2966. _Compare __comp, _IsVector __is_vector, /*is_parallel=*/std::true_type)
  2967. {
  2968. const auto __n1 = __last1 - __first1;
  2969. const auto __n2 = __last2 - __first2;
  2970. // use serial algorithm
  2971. if (__n1 + __n2 <= __set_algo_cut_off)
  2972. return std::set_symmetric_difference(__first1, __last1, __first2, __last2, __result, __comp);
  2973. typedef typename std::iterator_traits<_OutputIterator>::value_type _Tp;
  2974. return __internal::__parallel_set_union_op(
  2975. std::forward<_ExecutionPolicy>(__exec), __first1, __last1, __first2, __last2, __result, __comp,
  2976. [](_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2, _ForwardIterator2 __last2,
  2977. _Tp* __result, _Compare __comp) {
  2978. return __pstl::__utils::__set_symmetric_difference_construct(__first1, __last1, __first2, __last2, __result,
  2979. __comp, __BrickCopyConstruct<_IsVector>());
  2980. },
  2981. __is_vector);
  2982. }
  2983. //------------------------------------------------------------------------
  2984. // is_heap_until
  2985. //------------------------------------------------------------------------
  2986. template <class _RandomAccessIterator, class _Compare>
  2987. _RandomAccessIterator
  2988. __brick_is_heap_until(_RandomAccessIterator __first, _RandomAccessIterator __last, _Compare __comp,
  2989. /* __is_vector = */ std::false_type) noexcept
  2990. {
  2991. return std::is_heap_until(__first, __last, __comp);
  2992. }
  2993. template <class _RandomAccessIterator, class _Compare>
  2994. _RandomAccessIterator
  2995. __brick_is_heap_until(_RandomAccessIterator __first, _RandomAccessIterator __last, _Compare __comp,
  2996. /* __is_vector = */ std::true_type) noexcept
  2997. {
  2998. if (__last - __first < 2)
  2999. return __last;
  3000. typedef typename std::iterator_traits<_RandomAccessIterator>::difference_type _SizeType;
  3001. return __unseq_backend::__simd_first(
  3002. __first, _SizeType(0), __last - __first,
  3003. [&__comp](_RandomAccessIterator __it, _SizeType __i) { return __comp(__it[(__i - 1) / 2], __it[__i]); });
  3004. }
  3005. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  3006. _RandomAccessIterator
  3007. __pattern_is_heap_until(_ExecutionPolicy&&, _RandomAccessIterator __first, _RandomAccessIterator __last,
  3008. _Compare __comp, _IsVector __is_vector, /* is_parallel = */ std::false_type) noexcept
  3009. {
  3010. return __internal::__brick_is_heap_until(__first, __last, __comp, __is_vector);
  3011. }
  3012. template <class _RandomAccessIterator, class _DifferenceType, class _Compare>
  3013. _RandomAccessIterator
  3014. __is_heap_until_local(_RandomAccessIterator __first, _DifferenceType __begin, _DifferenceType __end, _Compare __comp,
  3015. /* __is_vector = */ std::false_type) noexcept
  3016. {
  3017. _DifferenceType __i = __begin;
  3018. for (; __i < __end; ++__i)
  3019. {
  3020. if (__comp(__first[(__i - 1) / 2], __first[__i]))
  3021. {
  3022. break;
  3023. }
  3024. }
  3025. return __first + __i;
  3026. }
  3027. template <class _RandomAccessIterator, class _DifferenceType, class _Compare>
  3028. _RandomAccessIterator
  3029. __is_heap_until_local(_RandomAccessIterator __first, _DifferenceType __begin, _DifferenceType __end, _Compare __comp,
  3030. /* __is_vector = */ std::true_type) noexcept
  3031. {
  3032. return __unseq_backend::__simd_first(
  3033. __first, __begin, __end,
  3034. [&__comp](_RandomAccessIterator __it, _DifferenceType __i) { return __comp(__it[(__i - 1) / 2], __it[__i]); });
  3035. }
  3036. template <class _ExecutionPolicy, class _RandomAccessIterator, class _Compare, class _IsVector>
  3037. _RandomAccessIterator
  3038. __pattern_is_heap_until(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  3039. _Compare __comp, _IsVector __is_vector, /* is_parallel = */ std::true_type) noexcept
  3040. {
  3041. if (__last - __first < 2)
  3042. return __last;
  3043. return __internal::__except_handler([&]() {
  3044. return __parallel_find(
  3045. std::forward<_ExecutionPolicy>(__exec), __first, __last,
  3046. [__first, __comp, __is_vector](_RandomAccessIterator __i, _RandomAccessIterator __j) {
  3047. return __internal::__is_heap_until_local(__first, __i - __first, __j - __first, __comp, __is_vector);
  3048. },
  3049. std::less<typename std::iterator_traits<_RandomAccessIterator>::difference_type>(), /*is_first=*/true);
  3050. });
  3051. }
  3052. //------------------------------------------------------------------------
  3053. // min_element
  3054. //------------------------------------------------------------------------
  3055. template <typename _ForwardIterator, typename _Compare>
  3056. _ForwardIterator
  3057. __brick_min_element(_ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3058. /* __is_vector = */ std::false_type) noexcept
  3059. {
  3060. return std::min_element(__first, __last, __comp);
  3061. }
  3062. template <typename _ForwardIterator, typename _Compare>
  3063. _ForwardIterator
  3064. __brick_min_element(_ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3065. /* __is_vector = */ std::true_type) noexcept
  3066. {
  3067. #if _PSTL_UDR_PRESENT
  3068. return __unseq_backend::__simd_min_element(__first, __last - __first, __comp);
  3069. #else
  3070. return std::min_element(__first, __last, __comp);
  3071. #endif
  3072. }
  3073. template <typename _ExecutionPolicy, typename _ForwardIterator, typename _Compare, typename _IsVector>
  3074. _ForwardIterator
  3075. __pattern_min_element(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3076. _IsVector __is_vector, /* is_parallel = */ std::false_type) noexcept
  3077. {
  3078. return __internal::__brick_min_element(__first, __last, __comp, __is_vector);
  3079. }
  3080. template <typename _ExecutionPolicy, typename _RandomAccessIterator, typename _Compare, typename _IsVector>
  3081. _RandomAccessIterator
  3082. __pattern_min_element(_ExecutionPolicy&& __exec, _RandomAccessIterator __first, _RandomAccessIterator __last,
  3083. _Compare __comp, _IsVector __is_vector, /* is_parallel = */ std::true_type)
  3084. {
  3085. if (__first == __last)
  3086. return __last;
  3087. return __internal::__except_handler([&]() {
  3088. return __par_backend::__parallel_reduce(
  3089. std::forward<_ExecutionPolicy>(__exec), __first + 1, __last, __first,
  3090. [=](_RandomAccessIterator __begin, _RandomAccessIterator __end,
  3091. _RandomAccessIterator __init) -> _RandomAccessIterator {
  3092. const _RandomAccessIterator subresult =
  3093. __internal::__brick_min_element(__begin, __end, __comp, __is_vector);
  3094. return __internal::__cmp_iterators_by_values(__init, subresult, __comp);
  3095. },
  3096. [=](_RandomAccessIterator __it1, _RandomAccessIterator __it2) -> _RandomAccessIterator {
  3097. return __internal::__cmp_iterators_by_values(__it1, __it2, __comp);
  3098. });
  3099. });
  3100. }
  3101. //------------------------------------------------------------------------
  3102. // minmax_element
  3103. //------------------------------------------------------------------------
  3104. template <typename _ForwardIterator, typename _Compare>
  3105. std::pair<_ForwardIterator, _ForwardIterator>
  3106. __brick_minmax_element(_ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3107. /* __is_vector = */ std::false_type) noexcept
  3108. {
  3109. return std::minmax_element(__first, __last, __comp);
  3110. }
  3111. template <typename _ForwardIterator, typename _Compare>
  3112. std::pair<_ForwardIterator, _ForwardIterator>
  3113. __brick_minmax_element(_ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3114. /* __is_vector = */ std::true_type) noexcept
  3115. {
  3116. #if _PSTL_UDR_PRESENT
  3117. return __unseq_backend::__simd_minmax_element(__first, __last - __first, __comp);
  3118. #else
  3119. return std::minmax_element(__first, __last, __comp);
  3120. #endif
  3121. }
  3122. template <typename _ExecutionPolicy, typename _ForwardIterator, typename _Compare, typename _IsVector>
  3123. std::pair<_ForwardIterator, _ForwardIterator>
  3124. __pattern_minmax_element(_ExecutionPolicy&&, _ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3125. _IsVector __is_vector, /* is_parallel = */ std::false_type) noexcept
  3126. {
  3127. return __internal::__brick_minmax_element(__first, __last, __comp, __is_vector);
  3128. }
  3129. template <typename _ExecutionPolicy, typename _ForwardIterator, typename _Compare, typename _IsVector>
  3130. std::pair<_ForwardIterator, _ForwardIterator>
  3131. __pattern_minmax_element(_ExecutionPolicy&& __exec, _ForwardIterator __first, _ForwardIterator __last, _Compare __comp,
  3132. _IsVector __is_vector, /* is_parallel = */ std::true_type)
  3133. {
  3134. if (__first == __last)
  3135. return std::make_pair(__first, __first);
  3136. return __internal::__except_handler([&]() {
  3137. typedef std::pair<_ForwardIterator, _ForwardIterator> _Result;
  3138. return __par_backend::__parallel_reduce(
  3139. std::forward<_ExecutionPolicy>(__exec), __first + 1, __last, std::make_pair(__first, __first),
  3140. [=](_ForwardIterator __begin, _ForwardIterator __end, _Result __init) -> _Result {
  3141. const _Result __subresult = __internal::__brick_minmax_element(__begin, __end, __comp, __is_vector);
  3142. return std::make_pair(
  3143. __internal::__cmp_iterators_by_values(__subresult.first, __init.first, __comp),
  3144. __internal::__cmp_iterators_by_values(__init.second, __subresult.second, std::not_fn(__comp)));
  3145. },
  3146. [=](_Result __p1, _Result __p2) -> _Result {
  3147. return std::make_pair(
  3148. __internal::__cmp_iterators_by_values(__p1.first, __p2.first, __comp),
  3149. __internal::__cmp_iterators_by_values(__p2.second, __p1.second, std::not_fn(__comp)));
  3150. });
  3151. });
  3152. }
  3153. //------------------------------------------------------------------------
  3154. // mismatch
  3155. //------------------------------------------------------------------------
  3156. template <class _ForwardIterator1, class _ForwardIterator2, class _BinaryPredicate>
  3157. std::pair<_ForwardIterator1, _ForwardIterator2>
  3158. __mismatch_serial(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  3159. _ForwardIterator2 __last2, _BinaryPredicate __pred)
  3160. {
  3161. #if _PSTL_CPP14_2RANGE_MISMATCH_EQUAL_PRESENT
  3162. return std::mismatch(__first1, __last1, __first2, __last2, __pred);
  3163. #else
  3164. for (; __first1 != __last1 && __first2 != __last2 && __pred(*__first1, *__first2); ++__first1, ++__first2)
  3165. {
  3166. }
  3167. return std::make_pair(__first1, __first2);
  3168. #endif
  3169. }
  3170. template <class _ForwardIterator1, class _ForwardIterator2, class _Predicate>
  3171. std::pair<_ForwardIterator1, _ForwardIterator2>
  3172. __brick_mismatch(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  3173. _ForwardIterator2 __last2, _Predicate __pred, /* __is_vector = */ std::false_type) noexcept
  3174. {
  3175. return __mismatch_serial(__first1, __last1, __first2, __last2, __pred);
  3176. }
  3177. template <class _ForwardIterator1, class _ForwardIterator2, class _Predicate>
  3178. std::pair<_ForwardIterator1, _ForwardIterator2>
  3179. __brick_mismatch(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  3180. _ForwardIterator2 __last2, _Predicate __pred, /* __is_vector = */ std::true_type) noexcept
  3181. {
  3182. auto __n = std::min(__last1 - __first1, __last2 - __first2);
  3183. return __unseq_backend::__simd_first(__first1, __n, __first2, std::not_fn(__pred));
  3184. }
  3185. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Predicate, class _IsVector>
  3186. std::pair<_ForwardIterator1, _ForwardIterator2>
  3187. __pattern_mismatch(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  3188. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _Predicate __pred, _IsVector __is_vector,
  3189. /* is_parallel = */ std::false_type) noexcept
  3190. {
  3191. return __internal::__brick_mismatch(__first1, __last1, __first2, __last2, __pred, __is_vector);
  3192. }
  3193. template <class _ExecutionPolicy, class _RandomAccessIterator1, class _RandomAccessIterator2, class _Predicate,
  3194. class _IsVector>
  3195. std::pair<_RandomAccessIterator1, _RandomAccessIterator2>
  3196. __pattern_mismatch(_ExecutionPolicy&& __exec, _RandomAccessIterator1 __first1, _RandomAccessIterator1 __last1,
  3197. _RandomAccessIterator2 __first2, _RandomAccessIterator2 __last2, _Predicate __pred,
  3198. _IsVector __is_vector, /* is_parallel = */ std::true_type) noexcept
  3199. {
  3200. return __internal::__except_handler([&]() {
  3201. auto __n = std::min(__last1 - __first1, __last2 - __first2);
  3202. auto __result = __internal::__parallel_find(
  3203. std::forward<_ExecutionPolicy>(__exec), __first1, __first1 + __n,
  3204. [__first1, __first2, __pred, __is_vector](_RandomAccessIterator1 __i, _RandomAccessIterator1 __j) {
  3205. return __internal::__brick_mismatch(__i, __j, __first2 + (__i - __first1), __first2 + (__j - __first1),
  3206. __pred, __is_vector)
  3207. .first;
  3208. },
  3209. std::less<typename std::iterator_traits<_RandomAccessIterator1>::difference_type>(), /*is_first=*/true);
  3210. return std::make_pair(__result, __first2 + (__result - __first1));
  3211. });
  3212. }
  3213. //------------------------------------------------------------------------
  3214. // lexicographical_compare
  3215. //------------------------------------------------------------------------
  3216. template <class _ForwardIterator1, class _ForwardIterator2, class _Compare>
  3217. bool
  3218. __brick_lexicographical_compare(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  3219. _ForwardIterator2 __last2, _Compare __comp,
  3220. /* __is_vector = */ std::false_type) noexcept
  3221. {
  3222. return std::lexicographical_compare(__first1, __last1, __first2, __last2, __comp);
  3223. }
  3224. template <class _ForwardIterator1, class _ForwardIterator2, class _Compare>
  3225. bool
  3226. __brick_lexicographical_compare(_ForwardIterator1 __first1, _ForwardIterator1 __last1, _ForwardIterator2 __first2,
  3227. _ForwardIterator2 __last2, _Compare __comp, /* __is_vector = */ std::true_type) noexcept
  3228. {
  3229. if (__first2 == __last2)
  3230. { // if second sequence is empty
  3231. return false;
  3232. }
  3233. else if (__first1 == __last1)
  3234. { // if first sequence is empty
  3235. return true;
  3236. }
  3237. else
  3238. {
  3239. typedef typename std::iterator_traits<_ForwardIterator1>::reference ref_type1;
  3240. typedef typename std::iterator_traits<_ForwardIterator2>::reference ref_type2;
  3241. --__last1;
  3242. --__last2;
  3243. auto __n = std::min(__last1 - __first1, __last2 - __first2);
  3244. std::pair<_ForwardIterator1, _ForwardIterator2> __result = __unseq_backend::__simd_first(
  3245. __first1, __n, __first2, [__comp](const ref_type1 __x, const ref_type2 __y) mutable {
  3246. return __comp(__x, __y) || __comp(__y, __x);
  3247. });
  3248. if (__result.first == __last1 && __result.second != __last2)
  3249. { // if first sequence shorter than second
  3250. return !__comp(*__result.second, *__result.first);
  3251. }
  3252. else
  3253. { // if second sequence shorter than first or both have the same number of elements
  3254. return __comp(*__result.first, *__result.second);
  3255. }
  3256. }
  3257. }
  3258. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Compare, class _IsVector>
  3259. bool
  3260. __pattern_lexicographical_compare(_ExecutionPolicy&&, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  3261. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _Compare __comp,
  3262. _IsVector __is_vector, /* is_parallel = */ std::false_type) noexcept
  3263. {
  3264. return __internal::__brick_lexicographical_compare(__first1, __last1, __first2, __last2, __comp, __is_vector);
  3265. }
  3266. template <class _ExecutionPolicy, class _ForwardIterator1, class _ForwardIterator2, class _Compare, class _IsVector>
  3267. bool
  3268. __pattern_lexicographical_compare(_ExecutionPolicy&& __exec, _ForwardIterator1 __first1, _ForwardIterator1 __last1,
  3269. _ForwardIterator2 __first2, _ForwardIterator2 __last2, _Compare __comp,
  3270. _IsVector __is_vector, /* is_parallel = */ std::true_type) noexcept
  3271. {
  3272. if (__first2 == __last2)
  3273. { // if second sequence is empty
  3274. return false;
  3275. }
  3276. else if (__first1 == __last1)
  3277. { // if first sequence is empty
  3278. return true;
  3279. }
  3280. else
  3281. {
  3282. typedef typename std::iterator_traits<_ForwardIterator1>::reference _RefType1;
  3283. typedef typename std::iterator_traits<_ForwardIterator2>::reference _RefType2;
  3284. --__last1;
  3285. --__last2;
  3286. auto __n = std::min(__last1 - __first1, __last2 - __first2);
  3287. auto __result = __internal::__parallel_find(
  3288. std::forward<_ExecutionPolicy>(__exec), __first1, __first1 + __n,
  3289. [__first1, __first2, &__comp, __is_vector](_ForwardIterator1 __i, _ForwardIterator1 __j) {
  3290. return __internal::__brick_mismatch(__i, __j, __first2 + (__i - __first1), __first2 + (__j - __first1),
  3291. [&__comp](const _RefType1 __x, const _RefType2 __y) {
  3292. return !__comp(__x, __y) && !__comp(__y, __x);
  3293. },
  3294. __is_vector)
  3295. .first;
  3296. },
  3297. std::less<typename std::iterator_traits<_ForwardIterator1>::difference_type>(), /*is_first=*/true);
  3298. if (__result == __last1 && __first2 + (__result - __first1) != __last2)
  3299. { // if first sequence shorter than second
  3300. return !__comp(*(__first2 + (__result - __first1)), *__result);
  3301. }
  3302. else
  3303. { // if second sequence shorter than first or both have the same number of elements
  3304. return __comp(*__result, *(__first2 + (__result - __first1)));
  3305. }
  3306. }
  3307. }
  3308. } // namespace __internal
  3309. } // namespace __pstl
  3310. #endif /* _PSTL_ALGORITHM_IMPL_H */