-
Notifications
You must be signed in to change notification settings - Fork 1k
/
EventStreamBenchmarks.cs
57 lines (46 loc) · 1.85 KB
/
EventStreamBenchmarks.cs
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
//-----------------------------------------------------------------------
// <copyright file="EventStreamBenchmarks.cs" company="Akka.NET Project">
// Copyright (C) 2009-2023 Lightbend Inc. <http://www.lightbend.com>
// Copyright (C) 2013-2023 .NET Foundation <https://github.com/akkadotnet/akka.net>
// </copyright>
//-----------------------------------------------------------------------
using Akka.Actor;
using Akka.Benchmarks.Configurations;
using BenchmarkDotNet.Attributes;
namespace Akka.Benchmarks.EventStream
{
[Config(typeof(MicroBenchmarkConfig))]
public class EventStreamBenchmarks
{
public const int NumOperations = 1_000_000;
internal sealed class FakeActor : MinimalActorRef
{
public override ActorPath Path { get; } = new RootActorPath(new Address("akka", "test")) / "fake";
public override IActorRefProvider Provider => throw new System.NotImplementedException();
public int LastMessage { get; private set; }
protected override void TellInternal(object message, IActorRef sender)
{
LastMessage++;
}
}
private FakeActor _fakeActor;
private Akka.Event.EventStream _eventStream;
private const string _msg = "foo";
[IterationSetup]
public void InitLogger()
{
_eventStream = new Event.EventStream(false);
_fakeActor = new FakeActor();
_eventStream.Subscribe(_fakeActor, typeof(string));
}
[Benchmark(OperationsPerInvoke = NumOperations)]
public object Publish()
{
for (var i = 0; i < NumOperations; i++)
{
_eventStream.Publish(_msg);
}
return _fakeActor.LastMessage;
}
}
}