Простой удаленный субъект / сервер: локальный клиент не остановится

Я начал использовать scala и мне действительно понравился язык, но мне, кажется, трудно понять, как работают актеры. Раньше я делал много своих удаленных вещей, используя NIO, но теперь я хочу попробовать удаленных актеров scala.

Я пытаюсь создать очень простой сервер и клиент (см. Код ниже).

  1. Сервер запущен
  2. Создан удаленный прокси-сервер для актера (следующий пример: http://www.scala-lang.org/docu/files/actors-api/actors_api_guide_6.html)
  3. Я отправляю сообщение на сервер через прокси, и оно проходит через
  4. Я хочу закрыть свое приложение..... Но как!?:). Это продолжается вечно

код:

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-й раз в поиске: это плохая практика - отправлять актеру сообщение от чего-то, что не является актером?

0 ответов

Другие вопросы по тегам