.Net4.0 Parallel編程(四)Task 上
在之前的文章中,已經介紹過了Parallel Loop(上、中、下)的相關內容。本篇文章中會就Task基礎部分進行些介紹。
初識Task
首先我們來構建一個簡單的Task的Demo:
static void Main(string[] args)
{
Task.Factory.StartNew(() =>
{
Console.WriteLine("Hello word!");
});
Console.Read();
}
{
Task.Factory.StartNew(() =>
{
Console.WriteLine("Hello word!");
});
Console.Read();
}
在上面這段代碼中我們構建出了一段非常簡單的使用Task類的代碼,通過其Factory屬性的創建出一個Task。其運行結果可想而知。其實上面的代碼跟:
static void Main(string[] args)
{
Task task = new Task(() =>
{
Console.WriteLine("Hello,Word!");
});
task.Start();
Console.Read();
}
{
Task task = new Task(() =>
{
Console.WriteLine("Hello,Word!");
});
task.Start();
Console.Read();
}
是一樣的,只是StartNew方法直接構建出了一個Task之后又調用了其Start方法。在Task內部執行的內容我們稱作為Task的Body,Task提供了多個初始化重載的方法。我們來看下面一個示例:
static void Main(string[] args)
{
Task task1 = new Task(() =>
{
Console.WriteLine("Message: Say \"Hello\" from task1");
});
Task task2 = new Task(new Action<object>(printMessage),
"Say \"Hello\" from task2");
Task task3 = new Task((obj) => { printMessage(obj); },
"Say \"Hello\" from task3");
Task task4 = new Task((obj) => { Console.WriteLine("Message: {0}", obj); },
"Say \"Hello\" from task4");
task1.Start();
task2.Start();
task3.Start();
task4.Start();
Console.Read();
}
{
Task task1 = new Task(() =>
{
Console.WriteLine("Message: Say \"Hello\" from task1");
});
Task task2 = new Task(new Action<object>(printMessage),
"Say \"Hello\" from task2");
Task task3 = new Task((obj) => { printMessage(obj); },
"Say \"Hello\" from task3");
Task task4 = new Task((obj) => { Console.WriteLine("Message: {0}", obj); },
"Say \"Hello\" from task4");
task1.Start();
task2.Start();
task3.Start();
task4.Start();
Console.Read();
}
上面的例子中使用了重載方法的State參數,其運行結果:
好像結果跟我們想象的優點不太一樣,其實我們仔細想想就可以理解了。
返回值
static void Main(string[] args)
{
var loop = 0;
var task1 = new Task<int>(() =>
{
for (var i = 0; i < 1000; i++)
loop += i;
return loop;
});
task1.Start();
var loopResut = task1.Result;
var task2 = new Task<long>(obj=>
{
long res = 0;
var looptimes = (int)obj;
for (var i = 0; i < looptimes; i++)
res += i;
return res;
},loopResut);
task2.Start();
var resultTask2 = task2.Result;
Console.WriteLine("Task1's result:{0}\nTask2's result:{1}",
loopResut,
resultTask2);
Console.ReadKey();
}
{
var loop = 0;
var task1 = new Task<int>(() =>
{
for (var i = 0; i < 1000; i++)
loop += i;
return loop;
});
task1.Start();
var loopResut = task1.Result;
var task2 = new Task<long>(obj=>
{
long res = 0;
var looptimes = (int)obj;
for (var i = 0; i < looptimes; i++)
res += i;
return res;
},loopResut);
task2.Start();
var resultTask2 = task2.Result;
Console.WriteLine("Task1's result:{0}\nTask2's result:{1}",
loopResut,
resultTask2);
Console.ReadKey();
}
運行的結果:
在這里要說的是,Result屬性的獲取是在一個Task運行完成才會獲取的,所以上面的task2是在task1運行完成后,才開始運行,也就是說上面的兩個result的值不管運行多少次都是不會變的。其中我們也可以通過CurrentId來獲取當前運行的Task的編號,但是要注意的一點,如果我們再Task的body之外獲取他將會返回null。
總結
在這篇文章中我們看到了如何創建一個Task,以及使用其返回值的屬性的介紹。下篇文中我們會看下如何取消一個Task。
全站熱搜