3

プロデューサー/コンシューマー タイプの Scala アプリを作成しようとしています。は継続的LoopControlにメッセージを送信します。 then デリゲートは に働きかけMessageReceiverます(オブジェクトのマップをチェックし、見つからない場合はマップを作成して起動します)。これによって作成されたそれぞれは、ID に関連付けられます。最終的には、ここでビジネス ロジックを実行したいと考えています。しかし、15分後にメモリが不足します。どんな助けでも大歓迎ですMessageReceiverMessageCreatorActorMessageActorMessageCreatorActor

import scala.actors.Actor
import java.util.HashMap;
import scala.actors.Actor._

case object LoopControl
case object MessageReceiver
case object MessageActor
case object MessageActorCreator

class MessageReceiver(msg: String) extends Actor {

 var messageActorMap = new HashMap[String, MessageActor]
 val messageCreatorActor  = new MessageActorCreator(null, null)

 def act() {
  messageCreatorActor.start
  loop {
   react {
   case MessageActor(messageId) =>   
   if (msg.length() > 0) {         
     var messageActor = messageActorMap.get(messageId);

     if(messageActor == null) {
      messageCreatorActor ! MessageActorCreator(messageId, messageActorMap)
     }else {   
      messageActor ! MessageActor
     }
    }
   }
  }
 }
}

case class MessageActorCreator(msg:String, messageActorMap: HashMap[String, MessageActor]) extends Actor {
 def act() {
   loop {
     react {
       case MessageActorCreator(messageId, messageActorMap) =>
         if(messageId != null ) {
    var messageActor = new MessageActor(messageId);
    messageActorMap.put(messageId, messageActor)
    println(messageActorMap)
    messageActor.start
    messageActor ! MessageActor
        }
     }
   }
    }
}

class LoopControl(messageReceiver:MessageReceiver) extends Actor {
  var count : Int = 0;
  def act() {
    while (true) {
          messageReceiver ! MessageActor ("00-122-0X95-FEC0" + count)
          //Thread.sleep(100)
          count = count +1;
          if(count > 5) {
           count = 0;
          }
    }
  }
}

case class MessageActor(msg: String) extends Actor {
 def act() {
   loop {
     react {
       case MessageActor =>
         println()
         println("MessageActor: Got something-> " + msg) 
     }
   }
    }
}

object messages extends Application {

 val messageReceiver = new MessageReceiver("bootstrap")
 val loopControl = new LoopControl(messageReceiver)

 messageReceiver.start
 loopControl.start
}
4

1 に答える 1

2

あなたのコードが実際にマップ内の既存のオブジェクトを見つけているかどうか疑問に思っていますか?

古いものが見つからない場合は、メモリが不足するまで新しい MessageActors を作成し続けます。

そのためにテストしてみてください。

于 2010-04-30T01:59:39.013 に答える