amir343

-module(test).

-export([ myfunc/1
        , myfunc/2
        ]).

%%Type alias:
type mywtf :: wtf(string, integer, atom).

%%Type constructor:

amir343

import org.openjdk.jmh.annotations.*;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.stream.IntStream;

amir343

L1 cache reference                  0.5 ns
Branch mispredict                   5 ns
L2 cache reference                  7 ns
Mutex lock/unlock                   25 ns
Main memory reference               100 ns
Compress 1K bytes with Zippy        3,000 ns
Send 2K bytes over 1 Gbps network   20,000 ns
Read 1 MB sequentially from memory  250,000 ns
Round trip within same datacenter   500,000 ns
Disk seek                           10,000,000 ns

amir343

import scala.collection.mutable.ListBuffer
import akka.actor.{Actor,ActorRef}
import akka.actor.Actor._
import akka.routing.{ Listeners, Listen }

//Represents a domain event
trait Event

//A builder to create domain entities
trait EntityBuilder[Entity] {

amir343

case class Account(name:String, username:String, password:String)

amir343

protected[this] override def newCombiner: Combiner[Char, ParallelString] = new ParallelStringCombiner

amir343

object Data {
  def apply(n:Int):List[Data] = {
    val r = new Random
    val lists = for { i <- 0 to n } yield new Data(r.nextInt(10000), r.nextInt(10000))
    lists.toList
  }
}

amir343

case class Firstname(name:String)

amir343

class BufferControl {
  def control(channel:NetworkChannel[String]) {

  }
}