Dziś porozmawiamy o wątkach w C#
Klasa
Task wymaga zastosowania następującej przestrzeni nazw:
using System.Threading.Tasks;
Jest kilka sposobów tworzenia wątków.. Stwórzmy do tego prostą metodę w Console Aplication:
public static int DoWork( int val )
{
var tmpVal = 0;
for ( int i = 0; i < val; i++ ) {
tmpVal += i;
}
return tmpVal;
}
static void Main( string[] args )
{
}
Przypominam że delegat Action umożliwia przypisanie metody zwracającej
void.
1) P
ierwszy ze sposobów to Lambda expression :
static void Main( string[] args )
{
const int taskLoop = 100;
var task = new Task<int>( () => DoWork( taskLoop ) );
task.Start();
Console.WriteLine( task.Result );
}
2) Lub..
static void Main( string[] args )
{
const int taskLoop = 100;
var task = new Task<int>( n => DoWork( (int)n ), taskLoop );
task.Start();
Console.WriteLine(task.Result);
}
3) Można również zastosować metodę "w locie" umieszczając ją w nawiasach:
static void Main( string[] args )
{
const int taskLoop = 100;
var task = new Task<int>( () => {
var tmpVal = 0;
for ( int i = 0; i < taskLoop; i++ ) {
tmpVal += i;
}
return tmpVal;
});
task.Start();
Console.WriteLine( task.Result );
}
Ważnym aspektem wątków jest możliwość ich przerwania w czasie wykonywania z poziomu wątku głównego można to powiązać z wyrzuceniem wyjątku:
public static int DoWork(CancellationToken ct, int val )
{
var tmpVal = 0;
for ( int i = 0; i < val; i++ ) {
tmpVal += i;
ct.ThrowIfCancellationRequested();
}
return tmpVal;
}
static void Main( string[] args )
{
const int taskLoop = 100;
CancellationTokenSource cs = new CancellationTokenSource();
var task = new Task<int>(() => DoWork(cs.Token,1000));
task.Start();
cs.Cancel();
try {
Console.WriteLine("Wynik to: {0}",task.Result);
}
catch ( AggregateException ex ) {
ex.Handle( e => e is OperationCanceledException );
Console.WriteLine("Operacja anulowana");
}
Powyższy kod spowoduje zatrzymanie wykonywania wątku już przy pierwszej pętli a to wszytko poprzez argument
CancellationTokenSource cs = new CancellationTokenSource(); który po wywołaniu metody Close() powoduje wyrzucenie wyjątku.
