1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
import scala.pickling.testing.PicklingBenchmark
import scala.util.Random
import scala.pickling._
import scala.pickling.Defaults._
import scala.pickling.binary._
import java.lang.{Runtime => JRuntime}
// for Java Serialization:
import java.io.{ByteArrayInputStream, ByteArrayOutputStream, ObjectOutputStream, ObjectInputStream}
object TraversableIntBenchFreeMem extends scala.pickling.testing.PicklingBenchmark {
override val enableOutput = false
val coll = (1 to size).toVector
val runtime = JRuntime.getRuntime
override def run() {
val pickle = coll.pickle
val res = pickle.unpickle[Vector[Int]]
println(runtime.freeMemory + "\t" + runtime.totalMemory)
}
}
object TraversableJavaIntBenchFreeMem extends scala.pickling.testing.PicklingBenchmark {
override val enableOutput = false
val coll = (1 to size).toVector
val runtime = JRuntime.getRuntime
override def run() {
val bos = new ByteArrayOutputStream()
val out = new ObjectOutputStream(bos)
out.writeObject(coll)
val ba = bos.toByteArray()
// println("Bytes: " + ba.length)
val bis = new ByteArrayInputStream(ba)
val in = new ObjectInputStream(bis)
val res = in.readObject.asInstanceOf[Vector[Int]]
println(runtime.freeMemory + "\t" + runtime.totalMemory)
}
}
object TraversableKryoIntBenchFreeMem extends scala.pickling.testing.PicklingBenchmark {
override val enableOutput = false
var ser: KryoSerializer = _
val coll = (1 to size).toVector
val runtime = JRuntime.getRuntime
override def tearDown() {
ser = null
}
override def run() {
val rnd: Int = Random.nextInt(10)
val arr = Array.ofDim[Byte](32 * 2048 * 2048 + rnd)
ser = new KryoSerializer
val pickled = ser.toBytes(coll, arr)
val unpickled = ser.fromBytes[List[Int]](pickled)
println(runtime.freeMemory + "\t" + runtime.totalMemory)
}
}
|
