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

use new Array instead of Array.ofDim

Browse source 
* to avoid allocations of ClassTag and other overhead of ofDim
This commit is contained in:
Patrik Nordwall 2017-03-09 17:35:02 +01:00
parent f542ce885c
commit 305347d396
10 changed files with 18 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala
View file

@ -79,8 +79,7 @@ object GraphInterpreter {
var outOwnerId: Int,
var outOwner: GraphStageLogic,
var inHandler: InHandler,
var outHandler: OutHandler
) {
var outHandler: OutHandler) {
var portState: Int = InReady
var slot: Any = Empty
@ -225,7 +224,7 @@ final class GraphInterpreter(
// An event queue implemented as a circular buffer
// FIXME: This calculates the maximum size ever needed, but most assemblies can run on a smaller queue
private[this] val eventQueue = Array.ofDim[Connection](1 << (32 - Integer.numberOfLeadingZeros(connections.length - 1)))
private[this] val eventQueue = new Array[Connection](1 << (32 - Integer.numberOfLeadingZeros(connections.length - 1)))
private[this] val mask = eventQueue.length - 1
private[this] var queueHead: Int = 0
private[this] var queueTail: Int = 0