-
Notifications
You must be signed in to change notification settings - Fork 1k
/
CallingThreadExecutor.cs
42 lines (34 loc) · 1.16 KB
/
CallingThreadExecutor.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
//-----------------------------------------------------------------------
// <copyright file="CallingThreadExecutor.cs" company="Akka.NET Project">
// Copyright (C) 2009-2021 Lightbend Inc. <http://www.lightbend.com>
// Copyright (C) 2013-2021 .NET Foundation <https://github.com/akkadotnet/akka.net>
// </copyright>
//-----------------------------------------------------------------------
using Akka.Configuration;
using Akka.Dispatch;
namespace Akka.Benchmarks.Dispatch
{
public class CallingThreadExecutor : ExecutorService
{
public CallingThreadExecutor(string id) : base(id)
{
}
public override void Execute(IRunnable run)
{
run.Run();
}
public override void Shutdown()
{
}
}
public class CallingThreadExecutorConfigurator : ExecutorServiceConfigurator
{
public CallingThreadExecutorConfigurator(Config config, IDispatcherPrerequisites prerequisites) : base(config, prerequisites)
{
}
public override ExecutorService Produce(string id)
{
return new CallingThreadExecutor(id);
}
}
}