patriknw

/**
 * Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
 */
package akka.event.japi

/**
 * Java API: See documentation for [[akka.event.EventBus]]
 * E is the Event type
 * S is the Subscriber type
 * C is the Classifier type

patriknw

Results of running PerformanceSpec for version 0.6 and 0.5 of akka-data-replication

== Version 0.6 ==

500 ORSet Update WriteOne took 43 ms, 11627 TPS
500 ORSet Update WriteOne took 9 ms, 55555 TPS
500 ORSet Update WriteOne took 8 ms, 62500 TPS
500 ORSet Update WriteOne took 8 ms, 62500 TPS
500 ORSet Update WriteOne took 5 ms, 100000 TPS

500 ORSet Update WriteOne took 6 ms, 83333 TPS

patriknw

package agent

import akka.agent.Agent
import akka.stm._

object AgentStmSample {

  def transfer(from: Agent[Int], to: Agent[Int], amount: Int): Boolean = {
    atomic {
      if (from.get < amount) false

patriknw

package sample

import akka.actor.Actor
import akka.actor.Props
import akka.dispatch.Await
import akka.util.duration._
import akka.util.Timeout
import akka.actor.ActorRef
import akka.actor.Terminated
import akka.actor.ActorSystem

patriknw

package akka.config.bean

import java.util.{ List ⇒ JList }
import java.util.{ ArrayList ⇒ JArrayList }
import java.util.{ HashMap ⇒ JHashMap }
import scala.reflect.BeanProperty
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory

class AkkaConfigBean {

patriknw

  case object Run
  case object Msg

  class Destination extends Actor {
    def receive = {
      case Msg ⇒ sender ! Msg
    }
  }

  class Client(

patriknw

package question

import java.io.IOException

import scala.util.Random

import akka.actor.Actor
import akka.actor.ActorRef
import akka.actor.ActorSystem
import akka.actor.OneForOneStrategy

patriknw

package perf

import akka.actor.ActorSystem
import akka.actor.Actor
import akka.actor.Props
import scala.concurrent.forkjoin.ThreadLocalRandom
import akka.routing.ConsistentHashingRouter
import akka.routing.ConsistentHashingRouter.ConsistentHashableEnvelope
import scala.util.Random
import akka.routing.Broadcast

patriknw

import akka.routing.ConsistentHashingRouter
import akka.routing.ConsistentHashingRouter.ConsistentHashMapping
import akka.actor.Actor
import akka.pattern.ask

case class Entry(key: String, value: String)

class Cache extends Actor {
  var cache = Map.empty[String, String]
 

patriknw

akka.actor.deployment {
  /statsService/workerRouter {
    router = round-robin
    nr-of-instances = 100
    cluster {
      enabled = on
      routees-path = "/user/statsWorker"
    }
  }
}