forked from EvilBeaver/OneScript
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathBslProcess.cs
More file actions
64 lines (54 loc) · 2.05 KB
/
BslProcess.cs
File metadata and controls
64 lines (54 loc) · 2.05 KB
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
/*----------------------------------------------------------
This Source Code Form is subject to the terms of the
Mozilla Public License, v.2.0. If a copy of the MPL
was not distributed with this file, You can obtain one
at http://mozilla.org/MPL/2.0/.
----------------------------------------------------------*/
using System;
using System.Collections.Generic;
using System.Linq;
using OneScript.Contexts;
using OneScript.DependencyInjection;
using OneScript.Execution;
using OneScript.Values;
using ScriptEngine.Machine;
namespace ScriptEngine
{
internal class BslProcess : IBslProcess
{
private readonly IExecutorProvider[] _executorProviders;
private readonly IDictionary<Type, Invoker> _bslExecutorsByModule;
private bool _isRunning;
public BslProcess(int id, ExecutionContext context, IEnumerable<IExecutorProvider> executorProviders)
{
_executorProviders = executorProviders.ToArray();
_bslExecutorsByModule =
_executorProviders.ToDictionary(item => item.SupportedModuleType, item => item.GetInvokeDelegate());
VirtualThreadId = id;
Services = context.Services.CreateScope();
}
public IServiceContainer Services { get; }
public int VirtualThreadId { get; }
public BslValue Run(BslObjectValue target, IExecutableModule module, BslScriptMethodInfo method, IValue[] arguments)
{
var notifyExecutors = !_isRunning;
if (notifyExecutors)
{
Array.ForEach(_executorProviders, e => e.BeforeProcessStart(this));
}
_isRunning = true;
try
{
return _bslExecutorsByModule[module.GetType()](this, target, module, method, arguments);
}
finally
{
if (notifyExecutors)
{
Array.ForEach(_executorProviders, e => e.AfterProcessExit(this));
_isRunning = false;
}
}
}
}
}