CSharpExamples/PLCnext_CSharpExamples/12_Threads/Threads.cs at master · PLCnext/CSharpExamples · GitHub

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
#region Copyright

//
// Copyright (c) Phoenix Contact GmbH & Co. KG. All rights reserved.
// Licensed under the MIT. See LICENSE file in the project root for full license information.
//

#endregion Copyright
usingIec61131.Engineering.Prototypes.Methods;
usingIec61131.Engineering.Prototypes.Types;
usingIec61131.Engineering.Prototypes.Variables;
usingSystem.Threading;

namespaceExampleLib
{
[FunctionBlock]
publicclassThreads
{
[InOut]
publicboolstartThread;

[Input]
publicshortsetPrio;

[Initialization]
publicvoid__Init()
{
//
// TODO: Initialize the variables of the function block here
//
}

[Execution]
publicvoid__Process()
{
if(startThread)
{
// Create the thread object, passing in the
// serverObject.StaticMethod method using a
// ThreadStart delegate.
ThreadStaticCaller=newThread(
newThreadStart(ServerClass.ThreadBody));

switch(setPrio)
{
case100:
StaticCaller.Priority=ThreadPriority.Lowest;
StaticCaller.Name="cs_lowest";
break;

case101:
StaticCaller.Priority=ThreadPriority.BelowNormal;
StaticCaller.Name="cs_bnormal";
break;

case102:
StaticCaller.Priority=ThreadPriority.Normal;
StaticCaller.Name="cs_normal";
break;

case103:
StaticCaller.Priority=ThreadPriority.AboveNormal;
StaticCaller.Name="cs_anormal";
break;

case104:
StaticCaller.Priority=ThreadPriority.Highest;
StaticCaller.Name="cs_higest";
break;

default:
// It is possible to cast integers from 0-99 as
// ThreadPriority. Like in C++ its not recommended
// to run threads in higher priority.
StaticCaller.Priority=(ThreadPriority)setPrio;
StaticCaller.Name="cs_prio"+setPrio;
break;
}

StaticCaller.Start();
startThread=false;
}
}
}

publicclassServerClass
{
publicstaticvoidThreadBody()
{
inta=0;
intb=1;
intn=300000;
// In N steps compute Fibonacci sequence iteratively.
for(inti=0;i<n;i++)
{
inttemp=a;
a=b;
b=temp+b;
}

// Pause for a moment to provide a delay to make
// threads more apparent.
Thread.Sleep(60000);
}
}
}