Skip to content

Commit

Permalink
Update copyright year
Browse files Browse the repository at this point in the history
  • Loading branch information
@qwwdfsad
qwwdfsad committed Feb 18, 2020
1 parent bf9509d commit 6d1a6e3
Show file tree
Hide file tree
Showing 324 changed files with 469 additions and 446 deletions.
2 changes: 1 addition & 1 deletion benchmarks/build.gradle
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
sourceCompatibility = 1.8
targetCompatibility = 1.8
Expand Down
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/java/benchmarks/flow/scrabble/RxJava2PlaysScrabble.java
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble;
Expand Down Expand Up @@ -160,4 +160,4 @@ public List<Entry<Integer, List<String>>> play() throws Exception {
.blockingGet() ;
return finalList2 ;
}
}
}
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/java/benchmarks/flow/scrabble/RxJava2PlaysScrabbleOpt.java
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble;
Expand Down Expand Up @@ -171,4 +171,4 @@ public List<Entry<Integer, List<String>>> play() throws Exception {

return finalList2 ;
}
}
}
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/FlowableCharSequence.java
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble.optimizations;
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/FlowableSplit.java
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble.optimizations;
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/StringFlowable.java
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble.optimizations;
Expand Down
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/ChannelProducerConsumerBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks
Expand Down Expand Up @@ -147,4 +147,4 @@ private fun doWork(): Unit = Blackhole.consumeCPU(ThreadLocalRandom.current().ne

private const val WORK_MIN = 50L
private const val WORK_MAX = 100L
private const val APPROX_BATCH_SIZE = 100000
private const val APPROX_BATCH_SIZE = 100000
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/ChannelSinkBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks
Expand Down
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/ParametrizedDispatcherBase.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks
Expand Down Expand Up @@ -44,4 +44,4 @@ abstract class ParametrizedDispatcherBase : CoroutineScope {
closeable?.close()
}

}
}
6 changes: 5 additions & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/SemaphoreBenchmark.kt
View file
@@ -1,3 +1,7 @@
/*
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks

import benchmarks.common.*
Expand Down Expand Up @@ -85,4 +89,4 @@ enum class SemaphoreBenchDispatcherCreator(val create: (parallelism: Int) -> Cor

private const val WORK_INSIDE = 80
private const val WORK_OUTSIDE = 40
private const val BATCH_SIZE = 1000000
private const val BATCH_SIZE = 1000000
17 changes: 7 additions & 10 deletions benchmarks/src/jmh/kotlin/benchmarks/akka/PingPongAkkaBenchmark.kt
View file
@@ -1,18 +1,15 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.akka

import akka.actor.ActorRef
import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.UntypedAbstractActor
import com.typesafe.config.ConfigFactory
import akka.actor.*
import com.typesafe.config.*
import org.openjdk.jmh.annotations.*
import scala.concurrent.Await
import scala.concurrent.duration.Duration
import java.util.concurrent.CountDownLatch
import scala.concurrent.*
import scala.concurrent.duration.*
import java.util.concurrent.*

const val N_MESSAGES = 100_000

Expand Down Expand Up @@ -117,4 +114,4 @@ open class PingPongAkkaBenchmark {
}
}
}
}
}
18 changes: 7 additions & 11 deletions benchmarks/src/jmh/kotlin/benchmarks/akka/StatefulActorAkkaBenchmark.kt
View file
@@ -1,19 +1,15 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.akka

import akka.actor.ActorRef
import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.UntypedAbstractActor
import com.typesafe.config.ConfigFactory
import akka.actor.*
import com.typesafe.config.*
import org.openjdk.jmh.annotations.*
import scala.concurrent.Await
import scala.concurrent.duration.Duration
import java.util.concurrent.CountDownLatch
import java.util.concurrent.ThreadLocalRandom
import scala.concurrent.*
import scala.concurrent.duration.*
import java.util.concurrent.*

const val ROUNDS = 10_000
const val STATE_SIZE = 1024
Expand Down Expand Up @@ -171,4 +167,4 @@ open class StatefulActorAkkaBenchmark {
initLatch.countDown()
}
}
}
}
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/FlatMapMergeBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow
Expand Down Expand Up @@ -44,4 +44,4 @@ open class FlatMapMergeBenchmark {
}
}

}
}
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/FlowFlattenMergeBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow
Expand Down Expand Up @@ -60,4 +60,4 @@ enum class FlowsNumberStrategy(val get: (concurrency: Int) -> Int) {
// If you change this variable please be sure that you change variable elements in the generate_plots_flow_flatten_merge.py
// python script as well
private const val ELEMENTS = 100_000
private const val WORK = 100
private const val WORK = 100
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/NumbersBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/


Expand Down Expand Up @@ -103,4 +103,4 @@ open class NumbersBenchmark {
.filter { (it + 1) % 3 == 0L }.count()
.blockingGet()
}
}
}
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/flow/SafeFlowBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/flow/TakeBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow
Expand Down
3 changes: 1 addition & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/FlowPlaysScrabbleBase.kt
View file
@@ -1,13 +1,12 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
import org.openjdk.jmh.annotations.*
import java.lang.Long.*
import java.lang.Long.max
import java.util.*
import java.util.concurrent.*
Expand Down
6 changes: 2 additions & 4 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/FlowPlaysScrabbleOpt.kt
View file
@@ -1,17 +1,15 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. and contributors Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
import org.openjdk.jmh.annotations.*
import java.lang.Long.max
import java.lang.Long.*
import java.util.*
import java.util.concurrent.*
import java.util.stream.*
import kotlin.math.*

@Warmup(iterations = 7, time = 1, timeUnit = TimeUnit.SECONDS)
@Measurement(iterations = 7, time = 1, timeUnit = TimeUnit.SECONDS)
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/IterableSpliterator.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble
Expand Down
4 changes: 1 addition & 3 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/ReactorPlaysScrabble.kt
View file
@@ -1,14 +1,12 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble

import org.openjdk.jmh.annotations.*
import reactor.core.publisher.*
import java.lang.Long.*
import java.util.*
import java.util.concurrent.*
import java.util.function.Function

/*@Warmup(iterations = 5, time = 1, timeUnit = TimeUnit.SECONDS)
Expand Down
6 changes: 1 addition & 5 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/SaneFlowPlaysScrabble.kt
View file
@@ -1,9 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble
Expand Down
3 changes: 1 addition & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/SequencePlaysScrabble.kt
View file
@@ -1,11 +1,10 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
import org.openjdk.jmh.annotations.*
import java.lang.Long.*
import java.util.*
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/ShakespearePlaysScrabble.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.flow.scrabble
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/scheduler/DispatchersContextSwitchBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler
Expand Down
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/scheduler/ForkJoinBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler
Expand Down Expand Up @@ -164,4 +164,4 @@ private fun compute(coefficients: LongArray, start: Int, end: Int): Double {
}

return result
}
}
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/scheduler/LaunchBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler
Expand Down Expand Up @@ -53,4 +53,4 @@ open class LaunchBenchmark : ParametrizedDispatcherBase() {
stopBarrier.reset()
}

}
}
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/scheduler/StatefulAwaitsBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler
Expand Down Expand Up @@ -117,4 +117,4 @@ open class StatefulAsyncBenchmark : ParametrizedDispatcherBase() {
}
sum
}
}
}
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ConcurrentStatefulActorBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler.actors
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/CycledActorsBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler.actors
Expand Down
4 changes: 2 additions & 2 deletions benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/PingPongActorBenchmark.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler.actors
Expand Down Expand Up @@ -100,4 +100,4 @@ fun CoroutineScope.pongActorCoroutine(capacity: Int = 1) =
else -> error("Cannot happen $message")
}
}
}
}
2 changes: 1 addition & 1 deletion benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/PingPongWithBlockingContext.kt
View file
@@ -1,5 +1,5 @@
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
* Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/

package benchmarks.scheduler.actors
Expand Down

0 comments on commit 6d1a6e3

Please sign in to comment.