Я пытаюсь одновременно писать в несколько файлов, используя инфраструктуру Akka. Сначала я создал класс с именем MyWriter, который записывает в файл, а затем, используя фьючерсы, я дважды вызываю объект, прыгая, что для меня будут созданы 2 файла, но когда я отслеживаю выполнения программы, она сначала заполняет первый файл, а затем второй (блокируя/синхронно).
В: как я могу запустить приведенный ниже код (без блокировки/асинхронно)
import akka.actor._
import akka.dispatch._
import akka.pattern.ask
import akka.util.Timeout
import scala.concurrent.Await
import scala.concurrent.duration._
import scala.concurrent.Future
import scala.concurrent.{ ExecutionContext, Promise }
import ExecutionContext.Implicits.global
class my_controler {
}
object Main extends App {
val system = ActorSystem("HelloSystem")
val myobj = system.actorOf(Props(new MyWriter), name = "myobj")
implicit val timeout = Timeout(50 seconds)
val future2 = Future { myobj ! save("lots of conentet") }
val future1 = Future { myobj ! save("event more lots of conentet") }
}
код MyWriter:
case class save(startval: String)
class MyWriter extends Actor {
def receive = {
case save(startval) => save_to_file(startval)
}
есть идеи, почему код не выполняется одновременно?
save
? - person om-nom-nom   schedule 19.05.2013