Простой удаленный субъект / сервер: локальный клиент не остановится
Я начал использовать scala и мне действительно понравился язык, но мне, кажется, трудно понять, как работают актеры. Раньше я делал много своих удаленных вещей, используя NIO, но теперь я хочу попробовать удаленных актеров scala.
Я пытаюсь создать очень простой сервер и клиент (см. Код ниже).
- Сервер запущен
- Создан удаленный прокси-сервер для актера (следующий пример: http://www.scala-lang.org/docu/files/actors-api/actors_api_guide_6.html)
- Я отправляю сообщение на сервер через прокси, и оно проходит через
- Я хочу закрыть свое приложение..... Но как!?:). Это продолжается вечно
код:
package testactors
import scala.collection.mutable.ArrayBuffer
import scala.actors._
import scala.actors.Actor._
import scala.actors.remote._
import scala.actors.remote.RemoteActor._
class Server extends Actor {
start
@volatile private var toLive = true
def act() {
alive(9000)
register('server, self)
while (toLive) {
receiveWithin(100) {
case TIMEOUT =>
case e => println(e)
}
}
println("Server died")
}
def killActor() {
toLive = false
}
}
object Main {
def main(args: Array[String]): Unit = {
val remoteSrc = new Server
println("Connecting to remote actor")
var localSrc = select(Node("localhost", 9000), 'server)
localSrc ! "hello"
Thread.sleep(1000)
println("Killing remote actor")
remoteSrc.killActor
}
}
Выход:
Connecting to remote actor
hello
Killing remote actor
Server died
Но это продолжается вечно..
ОБНОВИТЬ
ИЗВИНЯЮСЬ! Дубликат, нашел ответ в 3-й раз в поиске: это плохая практика - отправлять актеру сообщение от чего-то, что не является актером?