{"id":1712,"date":"2017-06-13T11:36:42","date_gmt":"2017-06-13T02:36:42","guid":{"rendered":"http:\/\/kazu.tv\/blog\/?p=1712"},"modified":"2017-06-13T12:48:19","modified_gmt":"2017-06-13T03:48:19","slug":"scala-parallel-collections-run-in-serial","status":"publish","type":"post","link":"https:\/\/kazu.tv\/blog\/2017\/06\/13\/scala-parallel-collections-run-in-serial\/","title":{"rendered":"Scala \u306e\u4e26\u5217\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u304c\u76f4\u5217\u3067\u3057\u304b\u52d5\u304b\u306a\u3044\u3068\u601d\u3063\u305f\u3089\u30fb\u30fb\u30fb"},"content":{"rendered":"

\u8ffd\u8a18<\/h1>\n

\u3084\u3063\u3071\u308a\u3001\u4e26\u5217\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3092\u4f7f\u3046\u306e\u306f\u3084\u3081\u3066\u3001Future \u4f7f\u3063\u3066\u3001Execution Context \u3068\u304b\u3092\u3061\u3083\u3093\u3068\u8a2d\u5b9a\u3059\u308b\u65b9\u6cd5\u306b\u3057\u305f\u3002<\/p>\n

\u304c\u3001\u4e00\u5fdc\u3001\u4ee5\u4e0b\u306e\u5185\u5bb9\u306f\u305d\u306e\u307e\u307e\u6b8b\u3057\u3066\u304a\u304f\u3002<\/p>\n

\u4e26\u5217\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3092\u4f7f\u3046\u52d5\u6a5f<\/h1>\n

\u4eca\u3001\u3044\u308d\u3093\u306a API \u304b\u3089\u30c7\u30fc\u30bf\u3092\u53d6\u3063\u3066\u304d\u3066\u3001\u305d\u308c\u3089\u3092\u691c\u7d22\u53ef\u80fd\u306b\u3059\u308b\u3063\u3066\u3044\u3046\uff08\u5143\u3005\u306f\u81ea\u5206\u7528\u306e\uff09\u30b5\u30fc\u30d3\u30b9\u3092\u3061\u3087\u3053\u3061\u3087\u3053\u4f5c\u3063\u3066\u3044\u308b\u3002\uff08\u8208\u5473\u306e\u3042\u308b\u65b9\u306f\u4ee5\u4e0b\u306e\u30ea\u30f3\u30af\u3088\u308a\u4f7f\u3063\u3066\u307f\u3066\u3001\u662f\u975e\u30d5\u30a3\u30fc\u30c9\u30d0\u30c3\u30af\u3092\u4e0b\u3055\u3044\u307e\u305b\u2193\uff09<\/p>\n

Track Down Anything on GitHub, Slack or Google Drive | Commet<\/a><\/p>\n

\u3044\u308d\u3093\u306a API \u304b\u3089\u30c7\u30fc\u30bf\u3092\u53d6\u3063\u3066\u304f\u308b\u306e\u3067\u3001\u76f4\u5217\u3067\u5b9f\u884c\u3059\u308b\u3068\u3001\u3069\u3063\u304b1\u7b87\u6240\u306e API \u304c\u4e0d\u8abf\u3060\u3063\u305f\u308a\u3057\u3066\u30ec\u30b9\u30dd\u30f3\u30b9\u304c\u9045\u3044\u3068\u3001\u305d\u308c\u306b\u5f15\u304d\u305a\u3089\u308c\u3066\u3057\u307e\u3046\u306e\u3067\u3001\u4e26\u5217\u5316\u3057\u3088\u3046\u3068\u601d\u3063\u305f\u3002<\/p>\n

\u30b3\u30fc\u30c9<\/h1>\n

\u5143\u3005\u306e\u30b3\u30fc\u30c9\u306f\u3001\u5927\u96d1\u628a\u306b\u306f\u3053\u3093\u306a\u611f\u3058\u3002<\/p>\n

\r\nSomeDatabase.findAllApiEndpointsToCall.foreach { apiCall =>\r\n  apiCall.execute\r\n}\r\n<\/pre>\n
\u3053\u308c\u3092\u4e26\u5217\u5316\u3057\u3088\u3046\u3068\u3057\u3066\u3001\u4ee5\u4e0b\u306e\u30b3\u30fc\u30c9\u306b\u3057\u305f\u3002<\/p>\n
\r\n# par \u3092\u3064\u3051\u305f\r\nSomeDatabase.findAllApiEndpointsToCall.par.foreach { apiCall =>\r\n  apiCall.execute\r\n}\r\n<\/pre>\n
\u30ed\u30b0\u3092\u307f\u308b\u3068\u3001<\/p>\n
\r\n02:08:35.008 [ForkJoinPool-3-worker-5] INFO xxxxx\r\n<\/pre>\n
\u3068\u3044\u3046\u611f\u3058\u3067\u3001\u5225\u30b9\u30ec\u30c3\u30c9\u3067\u52d5\u304f\u3088\u3046\u306b\u306a\u3063\u305f\u3088\u3046\u3060\u3051\u3069\u3001\u30b9\u30ec\u30c3\u30c9\u540d\u304c\u5e38\u306b\u540c\u3058\uff1d1\u3064\u306e\u30b9\u30ec\u30c3\u30c9\u3057\u304b\u4f7f\u308f\u308c\u3066\u3044\u306a\u3044\u3089\u3057\u3044\u3002<\/p>\n
\u4ee5\u4e0b\u306e\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u3092\u898b\u308b\u3068\u3001\u8a2d\u5b9a\u5909\u66f4\u51fa\u6765\u308b\u3089\u3057\u3044\u306e\u3067\u3001\u3084\u3063\u3066\u307f\u305f\u3002<\/p>\n
Parallel Collections – Configuring Parallel Collections – Scala Documentation<\/a><\/p>\n
\r\nval apiCalls = SomeDatabase.findAllApiEndpointsToCall.par\r\n\r\n# TaskSupport \u306a\u308b\u3082\u306e\u3092\u4f5c\u6210\u3057\u3066\u3001\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u306e\u30d7\u30ed\u30d1\u30c6\u30a3\u306b\u30bb\u30c3\u30c8\r\nval taskSupport = new ForkJoinTaskSupport(new scala.concurrent.forkjoin.ForkJoinPool(4)) # 4\u4e26\u5217\r\napiCalls.tasksupport = taskSupport\r\n\r\napiCalls.foreach { apiCall =&amp;gt;\r\n  apiCall.execute\r\n}\r\n<\/pre>\n
\u3053\u308c\u3067\u3001\u3068\u308a\u3042\u3048\u305a\u4e26\u5217\u3067\u51e6\u7406\u3055\u308c\u308b\u3088\u3046\u306b\u306a\u3063\u305f\u3002<\/p>\n
<\/p>\n
\u3053\u308c\u3067\u3044\u3044\u306e\u304b\uff1f<\/h1>\n
\u30e1\u30c7\u30bf\u30b7\u30e1\u30c7\u30bf\u30b7\u30fb\u30fb\u30fb\u3058\u3083\u306a\u3044\u6c17\u304c\u3059\u308b\u3002\u4e26\u5217\u51e6\u7406\u3092\u3057\u305f\u3044\u3068\u3053\u308d\u306f\u3001\u3053\u3053\u4ee5\u5916\u306b\u3082\u6ca2\u5c71\u3042\u308b\u3057\u3001\u305d\u306e\u5ea6\u306b tasksupport \u30d7\u30ed\u30d1\u30c6\u30a3\u3092\u30bb\u30c3\u30c8\u3059\u308b\u306e\u306f\u3060\u308b\u3044\u3002ExecutionContext \u307f\u305f\u3044\u306b\u3001\u8a2d\u5b9a\u30d5\u30a1\u30a4\u30eb\u3067\u7c21\u5358\u306b\u8a2d\u5b9a\u3067\u304d\u306a\u3044\u3082\u306e\u3060\u308d\u3046\u304b\u3002<\/p>\n
-D \u3068\u304b\u3067\u8a2d\u5b9a\u3067\u304d\u308b\u3089\u3057\u3044<\/h2>\n
parallel processing – Set the parallelism level for all collections in Scala 2.10? – Stack Overflow<\/a><\/p>\n
\u2191\u306e\u30da\u30fc\u30b8\u306b\u3088\u308c\u3070\u3001\u30b7\u30b9\u30c6\u30e0\u30d7\u30ed\u30d1\u30c6\u30a3\u3092\uff08-D \u3068\u304b setProperty \u3068\u304b\u3067\uff09\u30bb\u30c3\u30c8\u3059\u308c\u3070\u305d\u306e\u8a2d\u5b9a\u306b\u306a\u308b\u3089\u3057\u3044\u3002\u3046\u307e\u304f\u3044\u3063\u3066\u308b\u3063\u307d\u3044\u3002<\/p>\n
\u30d7\u30ed\u30d1\u30c6\u30a3\u3092\u3044\u3058\u308b\u3068\u304b\u3042\u307e\u308a\u3084\u3063\u305f\u3053\u3068\u306a\u3044\u3093\u3060\u3051\u3069\u3001\u3053\u3093\u306a\u611f\u3058\u3002<\/p>\n
\r\nval props = System.getProperties()\r\nprops.setProperty("scala.concurrent.context.minThreads", "2")\r\nprops.setProperty("scala.concurrent.context.numThreads", "x1.5")\r\nprops.setProperty("scala.concurrent.context.maxThreads", "4")\r\n<\/pre>\n
\u30d1\u30c3\u30b1\u30fc\u30b8\u30aa\u30d6\u30b8\u30a7\u30af\u30c8\u3092\u30ea\u30d5\u30ec\u30af\u30b7\u30e7\u30f3\u3067\u3044\u3058\u308b<\/h2>\n
\u4e0a\u306e\u65b9\u6cd5\u3067\u3046\u307e\u304f\u884c\u304b\u306a\u304b\u3063\u305f\u4eba\u304c\u3001\u5225\u306e\u65b9\u6cd5\u3092\u7de8\u307f\u51fa\u3057\u3066\u305f\u3002<\/p>\n
How do I set the default number of threads for Scala 2.10 parallel collections? – Stack Overflow<\/a><\/p>\n
scala.collection.parallel.`package` \u306e\u4e2d\u8eab\u3092\u30ea\u30d5\u30ec\u30af\u30b7\u30e7\u30f3\u3067\u3044\u3058\u308b\u3068\u3044\u3046\u3082\u306e\u3002\u30d0\u30fc\u30b8\u30e7\u30f3\u304c\u5909\u308f\u3063\u305f\u6642\u306b\u52d5\u304b\u306a\u304f\u306a\u308b\u53ef\u80fd\u6027\u3082\u3042\u308a\u305d\u3046\u3002<\/p>\n
\u307e\u3068\u3081<\/h1>\n
StackOverflow \u306e\u3069\u3063\u304b\u306b\u3082\u66f8\u3044\u3066\u3042\u3063\u305f\u3051\u3069\u3001\u30a4\u30f3\u30bf\u30fc\u30d5\u30a7\u30fc\u30b9\u3068\u3057\u3066\u4f7f\u3044\u3065\u3089\u3044\u3057\u3001\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u30821\u3064\u306e\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u306e\u8a2d\u5b9a\u3092\u5909\u66f4\u3059\u308b\u65b9\u6cd5\u3057\u304b\u66f8\u3044\u3066\u306a\u304f\u3066\u56f0\u308b\u3002\u4e26\u5217\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3063\u3066\u3001\u4f7f\u3063\u3066\u308b\u4eba\u304c\u3042\u307e\u308a\u3044\u306a\u3044\u306e\u3060\u308d\u3046\u304b\u3002<\/p>\n
 <\/p>\n
 <\/p>\n","protected":false},"excerpt":{"rendered":"
\u8ffd\u8a18 \u3084\u3063\u3071\u308a\u3001\u4e26\u5217\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3092\u4f7f\u3046\u306e\u306f\u3084\u3081\u3066\u3001Future \u4f7f\u3063\u3066\u3001Execution Context \u3068\u304b\u3092\u3061\u3083\u3093\u3068\u8a2d\u5b9a\u3059\u308b\u65b9\u6cd5\u306b\u3057\u305f\u3002 \u304c\u3001\u4e00\u5fdc\u3001\u4ee5\u4e0b\u306e\u5185\u5bb9\u306f\u305d\u306e\u307e\u307e\u6b8b\u3057\u3066\u304a\u304f\u3002 \u4e26\u5217\u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3092\u4f7f\u3046\u52d5\u6a5f \u4eca\u3001…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_monsterinsights_skip_tracking":false,"_monsterinsights_sitenote_active":false,"_monsterinsights_sitenote_note":"","_monsterinsights_sitenote_category":0,"footnotes":""},"categories":[20],"tags":[966,947],"class_list":["post-1712","post","type-post","status-publish","format-standard","hentry","category-scala","tag-parallel-collections","tag-scala"],"_links":{"self":[{"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts\/1712","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/comments?post=1712"}],"version-history":[{"count":6,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts\/1712\/revisions"}],"predecessor-version":[{"id":1718,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts\/1712\/revisions\/1718"}],"wp:attachment":[{"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/media?parent=1712"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/categories?post=1712"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/tags?post=1712"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}