raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

IO continuations seem to not suffer from stack overflow. yay!

Browse source
This commit is contained in:
Derek Williams 2011-06-04 21:21:02 -06:00
parent b1063e2940
commit 03997ef6bf
1 changed files with 39 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

46
akka-actor-tests/src/test/scala/akka/actor/actor/IOActor.scala
View file

@ -26,7 +26,10 @@ object IOActorSpec {
def receiveIO = {
case NewClient(server) ⇒
val socket = server.accept()
loopC { socket write socket.read() }
loopC {
val bytes = socket.read()
socket write bytes
}
}
})
@ -38,16 +41,21 @@ object IOActorSpec {
class SimpleEchoClient(host: String, port: Int, ioManager: ActorRef) extends Actor with IO {
var socket: SocketHandle = _
override def preStart: Unit = {
socket = connect(ioManager, host, port)
}
lazy val socket: SocketHandle = connect(ioManager, host, port)(Some(reader))
lazy val reader: ActorRef = Actor.actorOf {
new Actor with IO {
def receiveIO = {
case length: Int ⇒
val bytes = socket.read(length)
self reply bytes
}
}
}.start
def receiveIO = {
case bytes: ByteString ⇒
socket write bytes
self reply socket.read(bytes.length)
reader forward bytes.length
}
}
@ -177,6 +185,30 @@ class IOActorSpec extends WordSpec with MustMatchers with BeforeAndAfterEach {
ioManager.stop
}
"run echo server under high load" in {
val ioManager = Actor.actorOf(new IOManager()).start
val server = Actor.actorOf(new SimpleEchoServer("localhost", 8064, ioManager)).start
val client = Actor.actorOf(new SimpleEchoClient("localhost", 8064, ioManager)).start
val list = List.range(0, 100000)
val f: Future[List[ByteString]] = Future.traverse(list)(i ⇒ client !!! ByteString(i.toString))
assert(f.get.size === 100000)
client.stop
server.stop
ioManager.stop
}
"run echo server under high load with small buffer" in {
val ioManager = Actor.actorOf(new IOManager(2)).start
val server = Actor.actorOf(new SimpleEchoServer("localhost", 8064, ioManager)).start
val client = Actor.actorOf(new SimpleEchoClient("localhost", 8064, ioManager)).start
val list = List.range(0, 100000)
val f: Future[List[ByteString]] = Future.traverse(list)(i ⇒ client !!! ByteString(i.toString))
assert(f.get.size === 100000)
client.stop
server.stop
ioManager.stop
}
"run key-value store" in {
val ioManager = Actor.actorOf(new IOManager(2)).start // teeny tiny buffer
val server = Actor.actorOf(new KVStore("localhost", 8064, ioManager)).start