youmuliu/stgsharp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

daily update on 20241002 by nitload youmu, intrinsic function rebuild, syntax style arrange

Browse Source
This commit is contained in:
Nitload
2024-10-03 04:03:06 +08:00
parent 0979123ac0
commit 6e2f93b053
265 changed files with 26732 additions and 19058 deletions
Download Patch File Download Diff File Expand all files Collapse all files
源代码/StgSharp/Logic/Blueprint/Blueprint.cs
+38 -41
View File
@@ -30,7 +30,6 @@
//-----------------------------------------------------------------------
using StgSharp;
using System;
using System.Collections.Generic;
using System.Linq;
@@ -46,9 +45,8 @@ using System.Xml.Serialization;
namespace StgSharp.BluePrint
{
/// <summary>
/// A sets of complex logic designed for running in multi threads environment.
/// Warning: do not run a <see cref="Blueprint"/> instance in multi threads more than once.
///
/// A sets of complex logic designed for running in multi threads environment. Warning: do not
/// run a <see cref="Blueprint" /> instance in multi threads more than once.
/// </summary>
public partial class Blueprint : IConvertableToBlueprintNode
{
@@ -71,12 +69,13 @@ namespace StgSharp.BluePrint
allNode = new Dictionary<string, BlueprintNode>();
globalNodeList = new List<BlueprintNode>();
nativeNodeList = new List<BlueprintNode>();
runningStat = new SemaphoreSlim(1, 1);
beginNode = new BeginningNode(this);
endNode = new EndingNode(this);
runningStat = new SemaphoreSlim( 1, 1 );
beginNode = new BeginningNode( this );
endNode = new EndingNode( this );
}
public BlueprintNode BeginLayer => beginNode;
public BlueprintNode EndLayer => endNode;
public bool IsRunning
@@ -97,20 +96,21 @@ namespace StgSharp.BluePrint
}
/**/
public void AddNode(BlueprintNode node, bool isNative)
public void AddNode( BlueprintNode node, bool isNative )
{
_ = node ?? throw new ArgumentNullException(nameof(node));
_ = node ?? throw new ArgumentNullException( nameof( node ) );
node.IsNative = isNative;
allNode.Add(node.Name, node);
allNode.Add( node.Name, node );
}
public void ExecuteMain(in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output)
public void ExecuteMain(
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output )
{
BlueprintRunner.Run(this, () => true);
BlueprintRunner.Run( this, () => true );
}
[MethodImpl(MethodImplOptions.AggressiveInlining)]
[MethodImpl( MethodImplOptions.AggressiveInlining )]
public (string name, BlueprintPipelineArgs arg)[] GetOutput()
{
return endNode.OutputData;
@@ -118,52 +118,46 @@ namespace StgSharp.BluePrint
public void Init()
{
foreach (KeyValuePair<string, BlueprintNode> item in allNode)
{
if (item.Value.IsNative)
{
nativeNodeList.Add(item.Value);
}
else
{
globalNodeList.Add(item.Value);
foreach( KeyValuePair<string, BlueprintNode> item in allNode ) {
if( item.Value.IsNative ) {
nativeNodeList.Add( item.Value );
} else {
globalNodeList.Add( item.Value );
}
}
nativeNodeList.Sort();
globalNodeList.Sort();
}
[MethodImpl(MethodImplOptions.AggressiveInlining)]
public void SetInput(params (string name, BlueprintPipelineArgs arg)[] parameters)
[MethodImpl( MethodImplOptions.AggressiveInlining )]
public void SetInput(
params (string name, BlueprintPipelineArgs arg)[] parameters )
{
beginNode.InputData = parameters;
}
public void Terminate()
{
Interlocked.Exchange(ref currentGlobalNodeIndex, int.MaxValue);
Interlocked.Exchange(ref currentNativeNodeIndex, int.MaxValue);
Interlocked.Exchange( ref currentGlobalNodeIndex, int.MaxValue );
Interlocked.Exchange( ref currentNativeNodeIndex, int.MaxValue );
}
internal bool RequestNexGlobalNode(out BlueprintNode node)
internal bool RequestNexGlobalNode( out BlueprintNode node )
{
if (currentGlobalNodeIndex < globalNodeList.Count)
{
node = globalNodeList[currentGlobalNodeIndex];
Interlocked.Increment(ref currentGlobalNodeIndex);
if( currentGlobalNodeIndex < globalNodeList.Count ) {
node = globalNodeList[ currentGlobalNodeIndex ];
Interlocked.Increment( ref currentGlobalNodeIndex );
return true;
}
node = default!;
return false;
}
internal bool RequestNextNativeNode(out BlueprintNode node)
internal bool RequestNextNativeNode( out BlueprintNode node )
{
if (currentNativeNodeIndex < nativeNodeList.Count)
{
node = nativeNodeList[currentNativeNodeIndex];
Interlocked.Increment(ref currentNativeNodeIndex);
if( currentNativeNodeIndex < nativeNodeList.Count ) {
node = nativeNodeList[ currentNativeNodeIndex ];
Interlocked.Increment( ref currentNativeNodeIndex );
return true;
}
node = default!;
@@ -172,14 +166,17 @@ namespace StgSharp.BluePrint
string[] IConvertableToBlueprintNode.InputInterfacesName
{
get { return beginNode.OutputInterfaces.Select(p => p.Key).ToArray(); }
get { return beginNode.OutputInterfaces
.Select( p => p.Key )
.ToArray(); }
}
string[] IConvertableToBlueprintNode.OutputInterfacesName
{
get { return beginNode.OutputInterfaces.Select(p => p.Key).ToArray(); }
get { return beginNode.OutputInterfaces
.Select( p => p.Key )
.ToArray(); }
}
}
}
源代码/StgSharp/Logic/Blueprint/BlueprintActionNode.cs
+5 -7
View File
@@ -29,7 +29,6 @@
//-----------------------------------------------------------------------
//-----------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.Linq;
@@ -45,18 +44,17 @@ namespace StgSharp.BluePrint
private string[] outPorts;
private Action<Dictionary<string, BlueprintPipeline>, Dictionary<string, BlueprintPipeline>> mainAction;
internal BlueprintActionNode()
{
}
internal BlueprintActionNode() { }
public string[] InputInterfacesName => inPorts;
public string[] OutputInterfacesName => outPorts;
public void ExecuteMain(in Dictionary<string, BlueprintPipeline> input, in Dictionary<string, BlueprintPipeline> output)
public void ExecuteMain(
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output )
{
mainAction?.Invoke(input, output);
mainAction?.Invoke( input, output );
}
}
源代码/StgSharp/Logic/Blueprint/BlueprintNode.cs
+89 -114
View File
@@ -29,7 +29,6 @@
//-----------------------------------------------------------------------
//-----------------------------------------------------------------------
using StgSharp.Entities;
using System;
@@ -44,17 +43,16 @@ using System.Threading.Tasks;
namespace StgSharp.BluePrint
{
/// <summary>
///
///
/// </summary>
/// <risk>
/// Reset pipeline has risk, this operation is a direct operation to port
/// in current node, the port on the other node cannot get the change.
/// Reset pipeline has risk, this operation is a direct operation to port in current node, the
/// port on the other node cannot get the change.
/// </risk>
#pragma warning disable CA1036
public class BlueprintNode : IComparable<BlueprintNode>
#pragma warning restore CA1036
#pragma warning restore CA1036
{
private protected bool levelAvailable, nativeRequested;
@@ -64,8 +62,10 @@ namespace StgSharp.BluePrint
private IConvertableToBlueprintNode mainOperation;
private string name;
internal BlueprintNode(string name,
IConvertableToBlueprintNode node, bool isNative)
internal BlueprintNode(
string name,
IConvertableToBlueprintNode node,
bool isNative )
{
this.levelAvailable = false;
this.name = name;
@@ -73,45 +73,39 @@ namespace StgSharp.BluePrint
mainOperation = node;
_inputInterfaces = new Dictionary<string, BlueprintPipeline>();
_outputInterfaces = new Dictionary<string, BlueprintPipeline>();
foreach (string portName in node.InputInterfacesName)
{
_inputInterfaces.Add(portName, null!);
foreach( string portName in node.InputInterfacesName ) {
_inputInterfaces.Add( portName, null! );
}
foreach (string portName in node.OutputInterfacesName)
{
_outputInterfaces.Add(portName, null!);
foreach( string portName in node.OutputInterfacesName ) {
_outputInterfaces.Add( portName, null! );
}
}
#pragma warning disable CS8618
internal BlueprintNode(string name, bool isNative,
#pragma warning disable CS8618
internal BlueprintNode(
string name,
bool isNative,
string[] inputPorts,
string[] outputPorts
)
#pragma warning restore CS8618
string[] outputPorts )
#pragma warning restore CS8618
{
if ((inputPorts == null) || (inputPorts.Length == 0))
{
throw new ArgumentNullException(nameof(inputPorts));
if( ( inputPorts == null ) || ( inputPorts.Length == 0 ) ) {
throw new ArgumentNullException( nameof( inputPorts ) );
}
if ((outputPorts == null) || (outputPorts.Length == 0))
{
throw new ArgumentNullException(nameof(outputPorts));
if( ( outputPorts == null ) || ( outputPorts.Length == 0 ) ) {
throw new ArgumentNullException( nameof( outputPorts ) );
}
levelAvailable = false;
this.name = name;
IsNative = isNative;
_inputInterfaces = new Dictionary<string, BlueprintPipeline>();
_outputInterfaces = new Dictionary<string, BlueprintPipeline>();
foreach (string portName in inputPorts)
{
_inputInterfaces.Add(portName, null!);
foreach( string portName in inputPorts ) {
_inputInterfaces.Add( portName, null! );
}
foreach (string portName in outputPorts)
{
_outputInterfaces.Add(portName, null!);
foreach( string portName in outputPorts ) {
_outputInterfaces.Add( portName, null! );
}
}
@@ -125,19 +119,15 @@ namespace StgSharp.BluePrint
{
get
{
if (levelAvailable)
{
if( levelAvailable ) {
return _level;
}
_level = 0;
foreach (KeyValuePair<string, BlueprintPipeline> item in _inputInterfaces)
{
if (item.Value == null)
{
foreach( KeyValuePair<string, BlueprintPipeline> item in _inputInterfaces ) {
if( item.Value == null ) {
continue;
}
if (_level <= item.Value.Level)
{
if( _level <= item.Value.Level ) {
_level = item.Value.Level;
}
}
@@ -149,6 +139,7 @@ namespace StgSharp.BluePrint
public string Name => name;
internal Dictionary<string, BlueprintPipeline> InputInterfaces => _inputInterfaces;
internal Dictionary<string, BlueprintPipeline> OutputInterfaces => _outputInterfaces;
internal IConvertableToBlueprintNode Value
@@ -156,140 +147,124 @@ namespace StgSharp.BluePrint
get => mainOperation;
}
public void AddAfter(
BlueprintNode former,
string formerOutputPortName,
string thisInputPortName)
string thisInputPortName )
{
this.levelAvailable = false;
BlueprintPipeline pipeline = new BlueprintPipeline(former, this);
if (former is BeginningNode bnode)
{
bnode.SetCertainOutputPort(formerOutputPortName, pipeline);
BlueprintPipeline pipeline = new BlueprintPipeline( former, this );
if( former is BeginningNode bnode ) {
bnode.SetCertainOutputPort( formerOutputPortName, pipeline );
} else {
former.SetCertainOutputPort( formerOutputPortName, pipeline );
}
else
{
former.SetCertainOutputPort(formerOutputPortName, pipeline);
}
SetCertainInputPort(thisInputPortName, pipeline);
SetCertainInputPort( thisInputPortName, pipeline );
}
public void AddBefore(
BlueprintNode after,
string thisOutputPortName,
string afterInputPortName)
string afterInputPortName )
{
this.levelAvailable = false;
BlueprintPipeline pipeline = new BlueprintPipeline(this, after);
if (after is EndingNode enode)
{
enode.SetCertainInputPort(afterInputPortName, pipeline);
BlueprintPipeline pipeline = new BlueprintPipeline( this, after );
if( after is EndingNode enode ) {
enode.SetCertainInputPort( afterInputPortName, pipeline );
} else {
after.SetCertainInputPort( afterInputPortName, pipeline );
}
else
{
after.SetCertainInputPort(afterInputPortName, pipeline);
}
SetCertainOutputPort(thisOutputPortName, pipeline);
SetCertainOutputPort( thisOutputPortName, pipeline );
}
public int CompareTo(BlueprintNode other)
public int CompareTo( BlueprintNode other )
{
#pragma warning disable CA1062
return this.Level.CompareTo(other.Level);
#pragma warning restore CA1062
#pragma warning disable CA1062
return this.Level.CompareTo( other.Level );
#pragma warning restore CA1062
}
public virtual void Run()
{
try
{
try {
//Console.WriteLine(name);
BlueprintPipeline.WaitAll(_inputInterfaces);
if (mainOperation != null)
{
mainOperation.ExecuteMain(in _inputInterfaces, in _outputInterfaces);
BlueprintPipeline.WaitAll( _inputInterfaces );
if( mainOperation != null ) {
mainOperation.ExecuteMain(
in _inputInterfaces, in _outputInterfaces );
}
}
catch (Exception)
{
catch( Exception ) {
throw;
}
}
#region port operation
public BlueprintPipeline GetCertainInputPort(string name)
public BlueprintPipeline GetCertainInputPort( string name )
{
BlueprintPipeline ret;
if (!_inputInterfaces.TryGetValue(name, out ret))
{
throw new Exception($"Cannot find the interface named {name} in node {Name}.");
if( !_inputInterfaces.TryGetValue( name, out ret ) ) {
throw new Exception(
$"Cannot find the interface named {name} in node {Name}." );
}
return ret;
}
public BlueprintPipeline GetCertainOutputPort(string name)
public BlueprintPipeline GetCertainOutputPort( string name )
{
BlueprintPipeline ret;
if (!_outputInterfaces.TryGetValue(name, out ret))
{
throw new Exception($"Cannot find the interface named {name} in node {Name}.");
if( !_outputInterfaces.TryGetValue( name, out ret ) ) {
throw new Exception(
$"Cannot find the interface named {name} in node {Name}." );
}
return ret;
}
public void SetCertainInputPort(string name, BlueprintPipeline pipeline)
public void SetCertainInputPort(
string name,
BlueprintPipeline pipeline )
{
if (!_inputInterfaces.ContainsKey(name))
{
throw new Exception($"Cannot find the interface named {name} in node {Name}.");
if( !_inputInterfaces.ContainsKey( name ) ) {
throw new Exception(
$"Cannot find the interface named {name} in node {Name}." );
}
_inputInterfaces[name] = pipeline;
_inputInterfaces[ name ] = pipeline;
}
public void SetCertainOutputPort(string name, BlueprintPipeline pipeline)
public void SetCertainOutputPort(
string name,
BlueprintPipeline pipeline )
{
if (!_outputInterfaces.ContainsKey(name))
{
throw new Exception($"Cannot find the interface named {name} in node {Name}.");
if( !_outputInterfaces.ContainsKey( name ) ) {
throw new Exception(
$"Cannot find the interface named {name} in node {Name}." );
}
_outputInterfaces[name] = pipeline;
_outputInterfaces[ name ] = pipeline;
}
#endregion
}//--------------------------------- end of class -----------------------------------
public class BlueprintNodeRunException : Exception
{
protected BlueprintNodeRunException(SerializationInfo info, StreamingContext context) : base(info, context)
{
}
protected BlueprintNodeRunException(
SerializationInfo info,
StreamingContext context )
: base( info, context ) { }
public BlueprintNodeRunException()
{
}
public BlueprintNodeRunException() { }
public BlueprintNodeRunException(Exception ex) : base(string.Empty, ex)
{
}
public BlueprintNodeRunException( Exception ex )
: base( string.Empty, ex ) { }
public BlueprintNodeRunException(string message) : base(message)
{
}
public BlueprintNodeRunException( string message ) : base( message ) { }
public BlueprintNodeRunException(string message, Exception innerException) : base(message, innerException)
{
}
public BlueprintNodeRunException(
string message,
Exception innerException )
: base( message, innerException ) { }
}
}
源代码/StgSharp/Logic/Blueprint/BlueprintRunner.cs
+70 -79
View File
@@ -28,6 +28,9 @@
//
//-----------------------------------------------------------------------
//-----------------------------------------------------------------------
using StgSharp.Threading;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
@@ -36,9 +39,8 @@ using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using StgSharp.Threading;
using System.Threading.Tasks;
namespace StgSharp.BluePrint
{
@@ -46,33 +48,32 @@ namespace StgSharp.BluePrint
{
private static NodeRunner[] allAvailableTask = new NodeRunner[1];
private static CancellationTokenSource cts = new CancellationTokenSource();
private static ConcurrentStack<Blueprint> blueprintInWaiting = new ConcurrentStack<Blueprint>();
private static CancellationTokenSource cts = new CancellationTokenSource(
);
private static ConcurrentStack<Blueprint> blueprintInWaiting = new ConcurrentStack<Blueprint>(
);
private static int _callingThread;
private static SemaphoreSlim bpLock = new SemaphoreSlim(0, 1);
private static SemaphoreSlim bpLock = new SemaphoreSlim( 0, 1 );
internal static bool IsValidCalling
{
get
{
if ((NodeRunner.CurrentBlueprint == null) || //no bp running at all
((blueprintInWaiting.Count == 0) && (NodeRunner.CurrentBlueprint.IsRunning == false))) // a bp is quiting
if( ( NodeRunner.CurrentBlueprint == null ) || //no bp running at all
( ( blueprintInWaiting.Count == 0 ) && ( NodeRunner.CurrentBlueprint.IsRunning == false ) ) ) // a bp is quiting
{
//in case no bp is running
return true;
}
int? id = Task.CurrentId;
if (id is null)
{
if( id is null ) {
// in case calling from main thread and current running bp
//Console.WriteLine($"\t{_callingThread}");
//Console.WriteLine($"\t{Thread.CurrentThread.ManagedThreadId}");
return _callingThread == Thread.CurrentThread.ManagedThreadId;
}
foreach (NodeRunner item in allAvailableTask)
{
if (item.Id == id)
{
foreach( NodeRunner item in allAvailableTask ) {
if( item.Id == id ) {
//if calling from any bp running task
return true;
}
@@ -81,116 +82,105 @@ namespace StgSharp.BluePrint
}
}
public static void Run(Blueprint blueprint, Func<bool> terminateInstructor)
public static void Run(
Blueprint blueprint,
Func<bool> terminateInstructor )
{
//Console.WriteLine();
if (blueprint == null)
{
if( blueprint == null ) {
return;
}
if (terminateInstructor == null)
{
throw new ArgumentNullException(nameof(terminateInstructor));
if( terminateInstructor == null ) {
throw new ArgumentNullException( nameof( terminateInstructor ) );
}
if (blueprint.IsRunning)
{
throw new InvalidOperationException("Attempt to run a blueprint instance twice.");
if( blueprint.IsRunning ) {
throw new InvalidOperationException(
"Attempt to run a blueprint instance twice." );
}
blueprint.ShouldClose = terminateInstructor;
if (IsValidCalling)
{
if( IsValidCalling ) {
//Console.WriteLine("valid and run");
if (InterruptAndRunNewBp(blueprint))
{
do { } while (InterruptAndRunNewBp(NodeRunner.CurrentBlueprint));
if( InterruptAndRunNewBp( blueprint ) ) {
do { } while (InterruptAndRunNewBp(
NodeRunner.CurrentBlueprint ));
}
}
else
{
} else {
bpLock.Wait();
if (InterruptAndRunNewBp(blueprint))
{
do { } while (InterruptAndRunNewBp(NodeRunner.CurrentBlueprint));
if( InterruptAndRunNewBp( blueprint ) ) {
do { } while (InterruptAndRunNewBp(
NodeRunner.CurrentBlueprint ));
}
bpLock.Release();
}
Interlocked.Exchange(ref _callingThread, -1);
Interlocked.Exchange( ref _callingThread, -1 );
}
public static void SetMaxTaskCount(int size)
public static void SetMaxTaskCount( int size )
{
if (size < 1)
{
if( size < 1 ) {
size = 1;
}
if (allAvailableTask.Length >= size)
{
for (int i = size; i < allAvailableTask.Length; i++)
{
if (allAvailableTask[i] != null)
{
allAvailableTask[i].Cancel();
if( allAvailableTask.Length >= size ) {
for( int i = size; i < allAvailableTask.Length; i++ ) {
if( allAvailableTask[ i ] != null ) {
allAvailableTask[ i ].Cancel();
}
}
}
Array.Resize(ref allAvailableTask, size);
Array.Resize( ref allAvailableTask, size );
}
public static void Terminate()
{
cts.Cancel();
NodeRunner.CurrentBlueprint.Terminate();
foreach (NodeRunner task in allAvailableTask)
{
foreach( NodeRunner task in allAvailableTask ) {
task.Cts.Cancel();
}
foreach (Blueprint bp in blueprintInWaiting)
{
foreach( Blueprint bp in blueprintInWaiting ) {
bp.Terminate();
}
blueprintInWaiting.Clear();
}
internal static bool InterruptAndRunNewBp(Blueprint newBp)
internal static bool InterruptAndRunNewBp( Blueprint newBp )
{
Debug.Assert(newBp != null);
if ((newBp != NodeRunner.CurrentBlueprint) && (NodeRunner.CurrentBlueprint != null))
{
Debug.Assert( newBp != null );
if( ( newBp != NodeRunner.CurrentBlueprint ) && ( NodeRunner.CurrentBlueprint != null ) ) {
//if a running bp exists
blueprintInWaiting.Push(NodeRunner.CurrentBlueprint);
blueprintInWaiting.Push( NodeRunner.CurrentBlueprint );
}
//load new bp to current bp
Interlocked.Exchange(ref NodeRunner.CurrentBlueprint!, newBp);
Interlocked.Exchange(ref _callingThread, Thread.CurrentThread.ManagedThreadId);
Interlocked.Exchange( ref NodeRunner.CurrentBlueprint!, newBp );
Interlocked.Exchange(
ref _callingThread, Thread.CurrentThread.ManagedThreadId );
//run beginning node to init it first.
if (!NodeRunner.CurrentBlueprint.IsRunning)
{
(NodeRunner.CurrentBlueprint.BeginLayer as BeginningNode)!.Run();
if( !NodeRunner.CurrentBlueprint.IsRunning ) {
( NodeRunner.CurrentBlueprint.BeginLayer as BeginningNode )!.Run(
);
}
//refresh all tasks
for (int i = 0; i < allAvailableTask.Length; i++)
{
NodeRunner item = allAvailableTask[i];
if ((item is null) || item.IsCompleted)
{
allAvailableTask[i] = NodeRunner.Run();
for( int i = 0; i < allAvailableTask.Length; i++ ) {
NodeRunner item = allAvailableTask[ i ];
if( ( item is null ) || item.IsCompleted ) {
allAvailableTask[ i ] = NodeRunner.Run();
}
}
BlueprintNode node;
while (!cts.Token.IsCancellationRequested
&& NodeRunner.CurrentBlueprint.RequestNextNativeNode(out node))
{
while( !cts.Token.IsCancellationRequested && NodeRunner.CurrentBlueprint
.RequestNextNativeNode( out node ) ) {
node.Run();
if (!NodeRunner.CurrentBlueprint.IsRunning)
{
if( !NodeRunner.CurrentBlueprint.IsRunning ) {
break;
}
}
(NodeRunner.CurrentBlueprint.EndLayer as EndingNode)!.Run();
return blueprintInWaiting.TryPeek(out NodeRunner.CurrentBlueprint);
( NodeRunner.CurrentBlueprint.EndLayer as EndingNode )!.Run();
return blueprintInWaiting.TryPeek( out NodeRunner.CurrentBlueprint );
}
}
@@ -200,7 +190,8 @@ namespace StgSharp.BluePrint
private static Blueprint _current;
internal NodeRunner() : base()
internal NodeRunner()
: base()
{
_startup = InternalRun;
}
@@ -213,20 +204,20 @@ namespace StgSharp.BluePrint
internal static NodeRunner Run()
{
NodeRunner ret = new NodeRunner { _startup = InternalRun };
ret.taskInternal = Task.Run(ret.InternalAction);
ret._internalTask = Task.Run( ret.InternalAction );
return ret;
}
private static void InternalRun(CancellationToken token)
private static void InternalRun( CancellationToken token )
{
//Console.WriteLine("Task Begin");
BlueprintNode item;
while ((CurrentBlueprint != null) && CurrentBlueprint.IsRunning && !token.IsCancellationRequested
&& CurrentBlueprint.RequestNexGlobalNode(out item))
{
while( ( CurrentBlueprint != null ) && CurrentBlueprint.IsRunning && !token.IsCancellationRequested && CurrentBlueprint.RequestNexGlobalNode(
out item ) ) {
//Console.WriteLine($"Get node of {item.Name}, going to run.");
item.Run();
}
//Console.WriteLine("Task Completed");
}
源代码/StgSharp/Logic/Blueprint/BpNodeActionAttribute.cs
+9 -5
View File
@@ -34,8 +34,7 @@ using System.Text;
namespace StgSharp.BluePrint
{
[AttributeUsage(AttributeTargets.Method)]
[AttributeUsage( AttributeTargets.Method )]
public sealed class BpNodeActionAttribute : Attribute
{
@@ -43,21 +42,24 @@ namespace StgSharp.BluePrint
private string[] _output;
private int _operationSpan;
public BpNodeActionAttribute(int operationSpan)
public BpNodeActionAttribute( int operationSpan )
{
_input = Array.Empty<string>();
_output = Array.Empty<string>();
_operationSpan = operationSpan;
}
public BpNodeActionAttribute(string[] inputPort, string[] outputPort)
public BpNodeActionAttribute( string[] inputPort, string[] outputPort )
{
_input = inputPort;
_output = outputPort;
this._operationSpan = 1;
}
public BpNodeActionAttribute(string[] inputPort, string[] outputPort, int operationSpan)
public BpNodeActionAttribute(
string[] inputPort,
string[] outputPort,
int operationSpan )
{
_input = inputPort;
_output = outputPort;
@@ -65,7 +67,9 @@ namespace StgSharp.BluePrint
}
public string[] InputPort => _input;
public string[] OutputPort => _output;
public int OperationSpan => _operationSpan;
}
源代码/StgSharp/Logic/Blueprint/BpNodeBuilder.cs
+25 -20
View File
@@ -37,34 +37,39 @@ namespace StgSharp.BluePrint
public static class BpNodeConverter
{
public static IConvertableToBlueprintNode AsBlueprintNodeMainExecution(this BlueprintNodeOperation startUp)
public static IConvertableToBlueprintNode AsBlueprintNodeMainExecution(
this BlueprintNodeOperation startUp )
{
if (startUp == null)
{
throw new ArgumentNullException(nameof(startUp));
if( startUp == null ) {
throw new ArgumentNullException( nameof( startUp ) );
}
object[] attributeArray = startUp.Method.GetCustomAttributes(typeof(BpNodeActionAttribute), false);
BpNodeActionAttribute attri = (BpNodeActionAttribute)attributeArray[0];
if ((attributeArray.Length < 0) || (attri == null))
{
throw new InvalidCastException($"Delegate {nameof(startUp)} is not marked by {typeof(BpNodeActionAttribute)}");
object[] attributeArray = startUp.Method
.GetCustomAttributes( typeof( BpNodeActionAttribute ), false );
BpNodeActionAttribute attri = ( BpNodeActionAttribute )attributeArray[
0 ];
if( ( attributeArray.Length < 0 ) || ( attri == null ) ) {
throw new InvalidCastException(
$"Delegate {nameof(startUp)} is not marked by {typeof(BpNodeActionAttribute)}" );
}
return new DefaultConvertableToBlueprintNode(startUp, attri.InputPort, attri.OutputPort);
return new DefaultConvertableToBlueprintNode(
startUp, attri.InputPort, attri.OutputPort );
}
public static IConvertableToBlueprintNode AsBlueprintNodeMainExecution(this Action startUp)
public static IConvertableToBlueprintNode AsBlueprintNodeMainExecution(
this Action startUp )
{
if (startUp == null)
{
throw new ArgumentNullException(nameof(startUp));
if( startUp == null ) {
throw new ArgumentNullException( nameof( startUp ) );
}
object[] attributeArray = startUp.Method.GetCustomAttributes(typeof(BpNodeActionAttribute), false);
BpNodeActionAttribute attri = (BpNodeActionAttribute)attributeArray[0];
if ((attributeArray.Length < 0) || (attri == null))
{
throw new InvalidCastException($"Delegate {nameof(startUp)} is not marked by {typeof(BpNodeActionAttribute)}");
object[] attributeArray = startUp.Method
.GetCustomAttributes( typeof( BpNodeActionAttribute ), false );
BpNodeActionAttribute attri = ( BpNodeActionAttribute )attributeArray[
0 ];
if( ( attributeArray.Length < 0 ) || ( attri == null ) ) {
throw new InvalidCastException(
$"Delegate {nameof(startUp)} is not marked by {typeof(BpNodeActionAttribute)}" );
}
return new CrossFrameOperation(startUp, attri.OperationSpan);
return new CrossFrameOperation( startUp, attri.OperationSpan );
}
}
源代码/StgSharp/Logic/Blueprint/CrossFrameBlueprintNode.cs
+19 -14
View File
@@ -45,34 +45,39 @@ namespace StgSharp.BluePrint
private readonly int cycleCount;
public CrossFrameOperation(Action startup, int cycleCount)
public CrossFrameOperation( Action startup, int cycleCount )
{
MainExecution = startup;
this.cycleCount = (cycleCount > 1) ? cycleCount : throw new ArgumentException(
$"{$"The {typeof(CrossFrameOperation).Name} crosses only one cycle, "}{$"please use a {typeof(BlueprintNode).Name} instead."}");
this.cycleCount = ( cycleCount > 1 ) ?
cycleCount : throw new ArgumentException(
$"{$"The {typeof(CrossFrameOperation).Name} crosses only one cycle, "}{$"please use a {typeof(BlueprintNode).Name} instead."}" );
this.cycleCount = cycleCount;
currentCount = cycleCount;
}
public Action MainExecution { get; private protected set; }
public Action MainExecution
{
get;
private protected set;
}
public static string InputInterfacesName => "TaskIn";
public static string OutputInterfacesName => "TaskOut";
public void ExecuteMain(in Dictionary<string, BlueprintPipeline> input, in Dictionary<string, BlueprintPipeline> output)
public void ExecuteMain(
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output )
{
if (currentCount < cycleCount)
{
Interlocked.Increment(ref currentCount);
}
else
{
Interlocked.Exchange(ref currentCount, 0);
Task.Run(MainExecution);
if( currentCount < cycleCount ) {
Interlocked.Increment( ref currentCount );
} else {
Interlocked.Exchange( ref currentCount, 0 );
Task.Run( MainExecution );
}
//Console.WriteLine(currentCount);
BlueprintPipeline.SkipAll(output);
BlueprintPipeline.SkipAll( output );
}
string[] IConvertableToBlueprintNode.InputInterfacesName => [InputInterfacesName];
源代码/StgSharp/Logic/Blueprint/IConvertableToBlueprintNode.cs
+25 -15
View File
@@ -35,25 +35,30 @@ using System.Text;
namespace StgSharp.BluePrint
{
public delegate void BlueprintNodeOperation(in Dictionary<string, BlueprintPipeline> input, in Dictionary<string, BlueprintPipeline> output);
public delegate void BlueprintNodeOperation(
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output );
public interface IConvertableToBlueprintNode
{
#pragma warning disable CA1819
public string[] InputInterfacesName { get; }
#pragma warning restore CA1819
public string[] InputInterfacesName
{
get;
}
#pragma warning restore CA1819
#pragma warning disable CA1819
public string[] OutputInterfacesName { get; }
#pragma warning restore CA1819
#pragma warning disable CA1819
public string[] OutputInterfacesName
{
get;
}
#pragma warning restore CA1819
[MethodImpl(MethodImplOptions.AggressiveInlining)]
[MethodImpl( MethodImplOptions.AggressiveInlining )]
public void ExecuteMain(
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output);
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output );
}
@@ -64,16 +69,21 @@ namespace StgSharp.BluePrint
private string[] _output;
private BlueprintNodeOperation _execution;
public DefaultConvertableToBlueprintNode(BlueprintNodeOperation execution, string[] input, string[] output)
public DefaultConvertableToBlueprintNode(
BlueprintNodeOperation execution,
string[] input,
string[] output )
{
_input = input;
_output = output;
_execution = execution;
}
void IConvertableToBlueprintNode.ExecuteMain(in Dictionary<string, BlueprintPipeline> input, in Dictionary<string, BlueprintPipeline> output)
void IConvertableToBlueprintNode.ExecuteMain(
in Dictionary<string, BlueprintPipeline> input,
in Dictionary<string, BlueprintPipeline> output )
{
_execution(in input, in output);
_execution( in input, in output );
}
string[] IConvertableToBlueprintNode.InputInterfacesName => _input;
源代码/StgSharp/Logic/Blueprint/PipeLine.cs
+23 -26
View File
@@ -40,7 +40,6 @@ using System.Threading.Tasks;
namespace StgSharp.BluePrint
{
public class BlueprintPipeline
{
@@ -49,11 +48,12 @@ namespace StgSharp.BluePrint
private BlueprintPipelineArgs args;
private SemaphoreSlim formerCompleteSemaphore;
public BlueprintPipeline(BlueprintNode former, BlueprintNode after)
public BlueprintPipeline( BlueprintNode former, BlueprintNode after )
{
this.former = former;
this.after = after;
formerCompleteSemaphore = new SemaphoreSlim(initialCount: 0, maxCount: 1);
formerCompleteSemaphore = new SemaphoreSlim(
initialCount: 0, maxCount: 1 );
}
public BlueprintNode After => after;
@@ -68,31 +68,27 @@ namespace StgSharp.BluePrint
public int Level => former.Level;
public static void SkipAll(Dictionary<string, BlueprintPipeline> ports)
public static void SkipAll(
Dictionary<string, BlueprintPipeline> ports )
{
if (ports == null)
{
throw new ArgumentNullException(nameof(ports));
if( ports == null ) {
throw new ArgumentNullException( nameof( ports ) );
}
foreach (KeyValuePair<string, BlueprintPipeline> item in ports)
{
if (item.Value != null)
{
foreach( KeyValuePair<string, BlueprintPipeline> item in ports ) {
if( item.Value != null ) {
item.Value.CompleteAndSkip();
}
}
}
public static void WaitAll(Dictionary<string, BlueprintPipeline> ports)
public static void WaitAll(
Dictionary<string, BlueprintPipeline> ports )
{
if (ports == null)
{
throw new ArgumentNullException(nameof(ports));
if( ports == null ) {
throw new ArgumentNullException( nameof( ports ) );
}
foreach (KeyValuePair<string, BlueprintPipeline> item in ports)
{
if (item.Value != null)
{
foreach( KeyValuePair<string, BlueprintPipeline> item in ports ) {
if( item.Value != null ) {
item.Value.WaitForStart();
}
}
@@ -111,30 +107,31 @@ namespace StgSharp.BluePrint
#region pipline op
[MethodImpl(MethodImplOptions.AggressiveInlining)]
[MethodImpl( MethodImplOptions.AggressiveInlining )]
public void CompleteAndSkip()
{
//Console.WriteLine($"Complete\t{former.Name}\t->\t{after.Name}");
formerCompleteSemaphore.Release();
}
[MethodImpl(MethodImplOptions.AggressiveInlining)]
public void CompleteAndWriteData(BlueprintPipelineArgs args)
[MethodImpl( MethodImplOptions.AggressiveInlining )]
public void CompleteAndWriteData( BlueprintPipelineArgs args )
{
this.args = args;
CompleteAndSkip();
}
#endregion
}
public abstract class BlueprintPipelineArgs
{
public object? Value { get; set; }
public object? Value
{
get;
set;
}
}
}
源代码/StgSharp/Logic/Blueprint/RouteSwitch.cs
+25 -29
View File
@@ -42,28 +42,27 @@ namespace StgSharp.BluePrint
private protected Dictionary<string, (BlueprintPipeline pipeline, Func<bool> openingRule)> outputDictionary;
public RouteSwitch(string name, bool isNative, string inputPorts) :
base(name, isNative, [inputPorts], [string.Empty])
public RouteSwitch( string name, bool isNative, string inputPorts )
: base( name, isNative, [inputPorts], [string.Empty] )
{
outputDictionary = new Dictionary<string, (BlueprintPipeline pipeline, Func<bool> openingRule)>();
outputDictionary = new Dictionary<string, (BlueprintPipeline pipeline, Func<bool> openingRule)>(
);
}
public new int Level
{
get
{
if (levelAvailable)
{
if( levelAvailable ) {
return _level;
}
_level = 0;
KeyValuePair<string, BlueprintPipeline> item = _inputInterfaces.First();
if (item.Value == null)
{
KeyValuePair<string, BlueprintPipeline> item = _inputInterfaces.First(
);
if( item.Value == null ) {
throw new InvalidOperationException();
}
if (_level <= item.Value.Level)
{
if( _level <= item.Value.Level ) {
_level = item.Value.Level;
}
return _level;
@@ -73,43 +72,40 @@ namespace StgSharp.BluePrint
public new void AddBefore(
BlueprintNode after,
string thisOutputPortName,
string afterInputPortName)
string afterInputPortName )
{
this.AppendNode(after, afterInputPortName, () => true);
this.AppendNode( after, afterInputPortName, () => true );
}
public void AppendNode(BlueprintNode node, string portName, Func<bool> openningRule)
public void AppendNode(
BlueprintNode node,
string portName,
Func<bool> openningRule )
{
if (node == null)
{
throw new ArgumentNullException(nameof(node));
if( node == null ) {
throw new ArgumentNullException( nameof( node ) );
}
string indexName = $"{node.Name}.{portName}";
BlueprintPipeline p = new BlueprintPipeline(this, node);
node.InputInterfaces[portName] = p;
outputDictionary.Add(indexName, (p, openningRule));
BlueprintPipeline p = new BlueprintPipeline( this, node );
node.InputInterfaces[ portName ] = p;
outputDictionary.Add( indexName, (p, openningRule) );
}
public new void Run()
{
try
{
try {
BlueprintPipeline input = InputInterfaces.First().Value;
input.WaitForStart();
foreach (KeyValuePair<string, (BlueprintPipeline pipeline, Func<bool> openingRule)> item in outputDictionary)
{
if (item.Value.openingRule())
{
item.Value.pipeline.CompleteAndWriteData(input.Args);
foreach( KeyValuePair<string, (BlueprintPipeline pipeline, Func<bool> openingRule)> item in outputDictionary ) {
if( item.Value.openingRule() ) {
item.Value.pipeline.CompleteAndWriteData( input.Args );
}
}
}
catch (Exception)
{
catch( Exception ) {
throw;
}
}
}
}
源代码/StgSharp/Logic/Blueprint/SideNode.cs
+26 -25
View File
@@ -29,7 +29,6 @@
//-----------------------------------------------------------------------
//-----------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.Globalization;
@@ -45,8 +44,8 @@ namespace StgSharp.BluePrint
private Blueprint _bp;
public BeginningNode(Blueprint bp) : base(name: "BeginningNode", true, ["default"], ["default"]
)
public BeginningNode( Blueprint bp )
: base( name: "BeginningNode", true, ["default"], ["default"] )
{
_bp = bp;
}
@@ -55,13 +54,11 @@ namespace StgSharp.BluePrint
{
set
{
if (value == null)
{
if( value == null ) {
return;
}
foreach ((string name, BlueprintPipelineArgs arg) parameter in value)
{
OutputInterfaces[parameter.name].Args = parameter.arg;
foreach( (string name, BlueprintPipelineArgs arg) parameter in value ) {
OutputInterfaces[ parameter.name ].Args = parameter.arg;
}
}
}
@@ -69,16 +66,17 @@ namespace StgSharp.BluePrint
public override void Run()
{
_bp.RunningStat.Wait();
BlueprintPipeline.SkipAll(_outputInterfaces);
BlueprintPipeline.SkipAll( _outputInterfaces );
}
public new void SetCertainOutputPort(string name, BlueprintPipeline pipeline)
public new void SetCertainOutputPort(
string name,
BlueprintPipeline pipeline )
{
if (_outputInterfaces.ContainsKey(name))
{
_outputInterfaces[name] = pipeline;
if( _outputInterfaces.ContainsKey( name ) ) {
_outputInterfaces[ name ] = pipeline;
}
_outputInterfaces.Add(name, pipeline);
_outputInterfaces.Add( name, pipeline );
}
}
@@ -88,32 +86,35 @@ namespace StgSharp.BluePrint
private Blueprint _bp;
public EndingNode(Blueprint bp) : base(name: "EndingNode", true, ["default"], ["default"]
)
public EndingNode( Blueprint bp )
: base( name: "EndingNode", true, ["default"], ["default"] )
{
_bp = bp;
}
internal (string name, BlueprintPipelineArgs arg)[] OutputData
{
get { return InputInterfaces.Select(key => (key.Key, key.Value.Args)).ToArray(); }
get { return InputInterfaces.Select(
key => (key.Key, key.Value.Args) )
.ToArray(); }
}
public override void Run()
{
BlueprintPipeline.WaitAll(_inputInterfaces);
Interlocked.Exchange(ref _bp.currentGlobalNodeIndex, 0);
Interlocked.Exchange(ref _bp.currentNativeNodeIndex, 0);
BlueprintPipeline.WaitAll( _inputInterfaces );
Interlocked.Exchange( ref _bp.currentGlobalNodeIndex, 0 );
Interlocked.Exchange( ref _bp.currentNativeNodeIndex, 0 );
_bp.RunningStat.Release();
}
public new void SetCertainInputPort(string name, BlueprintPipeline pipeline)
public new void SetCertainInputPort(
string name,
BlueprintPipeline pipeline )
{
if (_inputInterfaces.ContainsKey(name))
{
_inputInterfaces[name] = pipeline;
if( _inputInterfaces.ContainsKey( name ) ) {
_inputInterfaces[ name ] = pipeline;
}
_inputInterfaces.Add(name, pipeline);
_inputInterfaces.Add( name, pipeline );
}
}