{"id":1309,"date":"2013-12-29T22:09:26","date_gmt":"2013-12-29T13:09:26","guid":{"rendered":"http:\/\/kazu.tv\/blog\/?p=1309"},"modified":"2014-01-01T21:06:02","modified_gmt":"2014-01-01T12:06:02","slug":"scala-future-with-play-blocking-issue","status":"publish","type":"post","link":"https:\/\/kazu.tv\/blog\/2013\/12\/29\/scala-future-with-play-blocking-issue\/","title":{"rendered":"Scala\u306eFuture\u304c\u30d6\u30ed\u30c3\u30af\u3059\u308b\uff1f\uff08\u6df1\u304f\u8abf\u3079\u3066\u306a\u3044\uff09"},"content":{"rendered":"<p>Scala\u306eFuture\u3067\uff08\u3042\u308b\u3044\u306fPlay\uff1f\uff09\u3067\u51e6\u7406\u304c\u30d6\u30ed\u30c3\u30af\u3055\u308c\u3066\u3057\u307e\u3046\u73fe\u8c61\u304c\u3042\u3063\u305f\u3002<\/p>\n<p>\u74b0\u5883<\/p>\n<ul>\n<li>Scala 2.10.1<\/li>\n<li>Play 2.1.3<\/li>\n<li>(Play\u306e\u30e2\u30c7\u30eb\u30af\u30e9\u30b9\u3092\u4f7f\u3063\u3066\u3044\u308b\u3060\u3051\u3067\u3001scala\u30b3\u30de\u30f3\u30c9\u304b\u3089\u8d77\u52d5\u3055\u308c\u308b\u30d0\u30c3\u30c1\u51e6\u7406)<\/li>\n<\/ul>\n<p>\u7c21\u7565\u5316\u3059\u308b\u3068\u3053\u3093\u306a\u30b3\u30fc\u30c9\uff08\u5b9f\u969b\u306f\u3082\u3063\u3068\u5206\u5272\u3055\u308c\u3066\u308b\u3057\u3001while\u3058\u3083\u306a\u304f\u3066tailrec\u3060\u3051\u3069\uff09\u3002<\/p>\n<pre class=\"brush: scala;\">import scala.concurrent.Await\r\nimport scala.concurrent.duration._\r\nimport play.api.libs.concurrent.Execution.Implicits._\r\n \r\nfor {\r\n  photo &lt;- listOfPhotos\r\n} yield {\r\n  \/\/ download\u306f\u30b5\u30fc\u30c9\u30d1\u30fc\u30c6\u30a3\u30e9\u30a4\u30d6\u30e9\u30ea\u306e\u30e1\u30bd\u30c3\u30c9\u3067\r\n  \/\/ Future\uff3bjava.io.File\uff3d\u3092\u8fd4\u3059\r\n  val fut = photo.download map { file =&gt;\r\n    Logger.debug(\"start!\") \/\/\u3053\u3053\u307e\u3067\u306f\u5b9f\u884c\u3055\u308c\u308b\u3002\r\n    \/\/ SomeApi.postFile\u306e\u6319\u52d5\u306f\u3001response\u304c\u8fd4\u308b\u307e\u3067\u30d6\u30ed\u30c3\u30af\u3059\u308b\u3002\r\n    \/\/ \u3057\u304b\u3057\u3001\u2193\u304c\u5b9f\u884c\u3055\u308c\u306a\u3044\r\n    SomeApi.postFile(file) map { jobId =&gt;\r\n      var complete = false\r\n      var result = None\r\n      while (!complete) {\r\n        Thread.sleep(5000)\r\n        val job = SomeApi.getJob(jobId)\r\n        if (job.isComplete()) {\r\n          complete = true\r\n          result = job.getResult()\r\n          \/\/ result\u306b\u5bfe\u3057\u3066\u51e6\u7406\r\n        }\r\n      }\r\n    }\r\n  }\r\n  try {\r\n    Await.result(fut, 120 seconds)\r\n  } catch {\r\n    case e: Exception =&gt; Logger.error(e.getMessage())\r\n  }\r\n}<\/pre>\n<p><!--more--><\/p>\n<h2>\u3068\u308a\u3042\u3048\u305a\u306e\u89e3\u6c7a\u7b56<\/h2>\n<p>Future\u306b\u95a2\u3059\u308b\u7406\u89e3\u304c\u7518\u304b\u3063\u305f\u306e\u3067\u3001\u52c9\u5f37\u3057\u3064\u3064\u8272\u3005\u8abf\u3079\u305f\u3093\u3060\u3051\u3069\u3001\u6839\u672c\u7684\u306a\u539f\u56e0\u306f\u826f\u304f\u5206\u304b\u3089\u306a\u304b\u3063\u305f\u3002\u3067\u3082\u3001\u3068\u308a\u3042\u3048\u305a\u306e\u89e3\u6c7a\u7b56\u304c\u898b\u3064\u304b\u3063\u305f\u3002\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u3001ExecutionContext\u3092\u5909\u3048\u308b\u3053\u3068\u3002<\/p>\n<pre class=\"brush: scala;\">\/\/import play.api.libs.concurrent.Execution.Implicits._ \/\/\u30b3\u30e1\u30f3\u30c8\u30a2\u30a6\u30c8\u3057\u3066\r\nimport scala.concurrent.ExecutionContext.Implicits.global \/\/\u3053\u3063\u3061\u3092\u8ffd\u52a0<\/pre>\n<p>Play\u306e\u30d0\u30b0\u306a\u306e\u304b\u3001\u81ea\u5206\u306e\u30b3\u30fc\u30c9\u304c\u60aa\u3044\u306e\u304b\u30fb\u30fb\u30fb\u305d\u306e\u3046\u3061Play 2.2\u306b\u30a2\u30c3\u30d7\u30b0\u30ec\u30fc\u30c9\u3059\u308b\u4e88\u5b9a\u306a\u306e\u3067\u3001\u305d\u3057\u305f\u3089\u518d\u5ea6\u8a66\u3057\u3066\u307f\u3088\u3046\u3002<\/p>\n<h2>\uff08\u8ffd\u8a18\uff09Play! 2.2\u3067\u306f\u76f4\u3063\u3066\u305f<\/h2>\n<p><a title=\"Play! framework 2.1 \u2192 2.2\u306b\u4e0a\u3052\u305f\" href=\"http:\/\/kazu.tv\/blog\/2014\/01\/01\/play-framework-2-1-to-2-2\/\">Play! 2.2\u306b\u30a2\u30c3\u30d7\u30b0\u30ec\u30fc\u30c9\u3057\u305f<\/a>\u3068\u3053\u308d\u3001\u554f\u984c\u306f\u89e3\u6d88\u3057\u305f\u3002<\/p>\n<h2>\u81ea\u5206\u7528\u30e1\u30e2<\/h2>\n<p>Future\u306b\u3064\u3044\u3066<\/p>\n<ul>\n<li><a title=\"Futures and Promises - Scala Documentation\" href=\"http:\/\/docs.scala-lang.org\/overviews\/core\/futures.html\" target=\"_blank\">Futures and Promises<\/a><\/li>\n<\/ul>\n<p>\u76f4\u5217\u3067\u5b9f\u884c<\/p>\n<ul>\n<li><a href=\"https:\/\/groups.google.com\/forum\/#!topic\/scala-user\/W9ykW8j3Ybg\" target=\"_blank\">[2.10] running futures in a for loop<\/a><\/li>\n<li><a title=\"how to do sequential execution of Futures in scala\" href=\"http:\/\/stackoverflow.com\/questions\/20414500\/how-to-do-sequential-execution-of-futures-in-scala\" target=\"_blank\">how to do sequential execution of Futures in scala<\/a><\/li>\n<\/ul>\n<p>\u8907\u6570\u306eFuture\u306e\u5b9f\u884c\u65b9\u6cd5\u8272\u3005<\/p>\n<ul>\n<li><a title=\" Asynchronous IO in Scala with futures\" href=\"http:\/\/stackoverflow.com\/questions\/13097754\/asynchronous-io-in-scala-with-futures\" target=\"_blank\"> Asynchronous IO in Scala with futures<\/a><\/li>\n<li><a title=\"Wait for several Futures\" href=\"http:\/\/stackoverflow.com\/questions\/16256279\/wait-for-several-futures\" target=\"_blank\">Wait for several Futures<\/a><\/li>\n<li><a title=\"Scala future sequence and timeout handling\" href=\"http:\/\/stackoverflow.com\/questions\/17672786\/scala-future-sequence-and-timeout-handling\" target=\"_blank\">Scala future sequence and timeout handling<\/a><\/li>\n<li><a title=\"Scala Futures - built in timeout?\" href=\"http:\/\/stackoverflow.com\/questions\/16304471\/scala-futures-built-in-timeout\/16305056#16305056\" target=\"_blank\">Scala Futures &#8211; built in timeout?<\/a><\/li>\n<\/ul>\n","protected":false},"excerpt":{"rendered":"<p>Scala\u306eFuture\u3067\uff08\u3042\u308b\u3044\u306fPlay\uff1f\uff09\u3067\u51e6\u7406\u304c\u30d6\u30ed\u30c3\u30af\u3055\u308c\u3066\u3057\u307e\u3046\u73fe\u8c61\u304c\u3042\u3063\u305f\u3002 \u74b0\u5883 Scala 2.10.1 Play 2.1.3 (Play\u306e\u30e2\u30c7\u30eb\u30af\u30e9\u30b9\u3092\u4f7f\u3063\u3066\u3044\u308b\u3060\u3051\u3067\u3001scala\u30b3\u30de\u30f3\u30c9\u304b\u3089\u8d77\u52d5\u3055\u308c&hellip;<\/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":[916,947],"class_list":["post-1309","post","type-post","status-publish","format-standard","hentry","category-scala","tag-play-framework","tag-scala"],"_links":{"self":[{"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts\/1309","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=1309"}],"version-history":[{"count":10,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts\/1309\/revisions"}],"predecessor-version":[{"id":1332,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/posts\/1309\/revisions\/1332"}],"wp:attachment":[{"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/media?parent=1309"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/categories?post=1309"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/kazu.tv\/blog\/wp-json\/wp\/v2\/tags?post=1309"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}