Task用的是線程池，線程池的線程數量的有上限的，這個可以通過ThreadPool修改，我們經常會用到task.run ,new task ,和task.factory.startnew方法來創建任務
Task.Factory.StartNew(action)不是直接創建線程，創建的是任務，它有一個任務隊列，然后通過任務調度器把任務分配到線程池中的空閑線程中，任務是不能被直接執行的，只有分配給線程才能被執行，如果任務的數量比線程池中的線程多，線程池的線程數量還沒有到達上限，就會創建新線程執行任務。如果線程池的線程已到達上限，沒有分配到線程的任務需要等待有線程空閑的時候才執行。
task 是新建一個異步任務，這個任務是分配到子線程中去的，跟我們之前的new thread，創建線程很相似，在子線程中，通過SynchronizationContext類進行上下文同步，實現子線程和主線程之間的通信。
ContinueWith：創建一個在目標 Task 完成時異步執行的延續任務，也就是Task完成后要執行的任務
示例代碼如下：
Task.Factory.StartNew(() =>
{
AddDr("select s_FilePathName from T_Files where isnull(s_FilePathName,'') <>''");
}).ContinueWith(i =>
{
this.Invoke(new Action(delegate
{
lblProcess.Text = "數據庫文件記錄讀取完成，共" + dt.Rows.Count + "個，開始執行復制...";
//讀取完成后，開始copy file
}));
});
task 和 thread ,以及thread pool區別：
Task是將多個操作封裝成一個概念上原子操作。但這個操作由哪個Thread甚至多個Thread來處理處理你並不清楚。總之就是可以被正常完成。
Thread僅僅是一條線程，所有操作都是這個Thread一個完成的。
thread是單核多線程，task是多核多線程
task 比thread pool 線程池優越的地方在於，在thread pool時期，我們不能知道一個workitem是否完成，也不能在完成后知道workitem所得出的返回值，task封裝后解決了這個問題，並且可以清楚地知道返回值。
附上我自己寫的一個文件復制的小demo代碼：
運行效果：
代碼如下：
----------------------------------------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace CopyFiles
{
public partial class Form1 : Form
{
delegate void AsynUpdateUI(int step);
public Form1()
{
InitializeComponent();
}
private void button1_Click(object sender, EventArgs e)
{
SqlConnection con = new SqlConnection(string.Format("server={0};database={1};user={2};pwd={3};", txtServer.Text, txtDB.Text, txtSa.Text, txtPwd.Text));
try
{
//2. 數據庫操作類 關鍵字SqlCommand
SqlCommand cm = con.CreateCommand();
//編寫TSQL語句
cm.CommandText = "select count(*) from TCase_Base";
//3. 數據庫連接通道開啟
//上面只是連接到了數據庫，並獲取到了數據庫的表的信息，需要開啟才能實現操作
con.Open();//開啟
//4. 數據讀取類 關鍵字SqlDataReader
SqlDataReader dq = cm.ExecuteReader();//讀取一下獲取到的數據庫數據
if (dq.HasRows) //if判斷是否能夠讀取到數據庫，讀取到了走里面程序，讀取不到說明有錯誤
{
while (dq.Read())//每次只讀取一條數據，加個循環，將每條數據循環讀取出來，每讀到一條數據返回的是true類型，當沒有數據的時候是false類型，自動結束循環
{
if (dq[0] != DBNull.Value)
{
}
}
}
MessageBox.Show("測試連接成功！");
}
catch (Exception ex)
{
MessageBox.Show("測試連接失敗！" + ex.Message);
}
finally
{
con.Close();//使用完之后關閉數據庫連接
}
}
private void button2_Click(object sender, EventArgs e)
{
FolderBrowserDialog dialog = new FolderBrowserDialog();
dialog.Description = "請選擇源文件目錄";
if (dialog.ShowDialog() == DialogResult.OK)
{
txtYFile.Text = dialog.SelectedPath;
}
}
private void button3_Click(object sender, EventArgs e)
{
FolderBrowserDialog dialog = new FolderBrowserDialog();
dialog.Description = "請選擇目標文件目錄";
if (dialog.ShowDialog() == DialogResult.OK)
{
txtTFile.Text = dialog.SelectedPath;
}
}
private DataTable dt;
private void button4_Click(object sender, EventArgs e)
{
if (txtYFile.Text == "" && txtTFile.Text == "")
{
MessageBox.Show("源文件目錄、目標文件目錄不能為空！");
return;
}
failList = new List<string>();
this.button4.Enabled = false;
dt = new DataTable();
dt.Columns.Add("filepath", typeof(string));
Task.Factory.StartNew(() =>
{
AddDr("select s_FilePathName from TFiles where isnull(s_FilePathName,'') <>''");
AddDr("select s_EmailPath from TEmail where isnull(s_EmailPath,'') <>''");
}).ContinueWith(i =>
{
this.Invoke(new Action(delegate
{
lblProcess.Text = "數據庫文件記錄讀取完成，共" + dt.Rows.Count + "個，開始執行復制...";
//讀取完成后，開始copy file
int taskCount = dt.Rows.Count;
this.pgbWrite.Maximum = taskCount;
this.pgbWrite.Value = 0;
UpdateUIDelegate += UpdataUIStatus;//綁定更新任務狀態的委托
TaskCallBack += Accomplish;//綁定完成任務要調用的委托
Thread thread = new Thread(Write);
thread.IsBackground = true;
thread.Start();
}));
});
}
private void AddDr(string sql)
{
SqlConnection con = new SqlConnection(string.Format("server={0};database={1};user={2};pwd={3};", txtServer.Text, txtDB.Text, txtSa.Text, txtPwd.Text));
try
{
SqlCommand cm = con.CreateCommand();
cm.CommandText = sql;
con.Open();
SqlDataReader dq = cm.ExecuteReader();
if (dq.HasRows)
{
while (dq.Read())
{
if (dq[0] != DBNull.Value && dq[0].ToString() != "")
{
DataRow dataRow = dt.NewRow();
dataRow["filepath"] = dq[0].ToString();
dt.Rows.Add(dataRow);
}
}
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
finally
{
con.Close();//使用完之后關閉數據庫連接
}
}
private void UpdataUIStatus(int step)
{
if (InvokeRequired)
{
this.Invoke(new AsynUpdateUI(delegate(int s)
{
this.pgbWrite.Value += s;
this.lblProcess.Text = "共" + dt.Rows.Count + "個，正在執行第" + this.pgbWrite.Value.ToString() + "個";
}), step);
}
else
{
this.pgbWrite.Value += step;
this.lblProcess.Text = "共" + dt.Rows.Count + "個，正在執行第" + this.pgbWrite.Value.ToString() + "個";
}
}
private void Accomplish()
{
//還可以進行其他的一些完任務完成之后的邏輯處理
if (InvokeRequired)
{
this.Invoke(new AsynUpdateUI(delegate(int s)
{
lblProcess.Text = "執行完成，共" + dt.Rows.Count + "個，" + success + "個成功，" + fail + "個失敗，" + noFile + "個不存在";
File.WriteAllLines(Application.StartupPath+"\\失敗的文件記錄.txt", failList);
}), 0);
}
else
{
lblProcess.Text = "執行完成，共" + dt.Rows.Count + "個，" + success + "個成功，" + fail + "個失敗，" + noFile + "個不存在";
File.WriteAllLines(Application.StartupPath + "\\失敗的文件記錄.txt", failList);
}
}
public delegate void UpdateUI(int step);//聲明一個更新主線程的委托
public UpdateUI UpdateUIDelegate;
public delegate void AccomplishTask();//聲明一個在完成任務時通知主線程的委托
public AccomplishTask TaskCallBack;
private int success;
private int fail;
private int noFile;
private List<string> failList;
public void Write()
{
foreach (DataRow dr in dt.Rows)
{
string yFile = txtYFile.Text + "\\" + dr["filepath"].ToString();
if (File.Exists(yFile))
{
string tFile = txtTFile.Text + "\\" + dr["filepath"].ToString();
string outmsg;
if (CopyFile(yFile, tFile, true, out outmsg))
{
success++;
}
else
{
failList.Add(yFile);
fail++;
}
}
else
{
noFile++;
}
//寫入一條數據，調用更新主線程ui狀態的委托
UpdateUIDelegate(1);
}
//任務完成時通知主線程作出相應的處理
TaskCallBack();
//將更新包信息寫入到客戶端文件配置中
Thread.Sleep(1000);
}
public static bool CopyFile(string sSource, string sTarget, bool bOverride, out string errorMessage)
{
errorMessage = null;
try
{
if (!Directory.Exists(Path.GetDirectoryName(sTarget)))
{ // 如果目標路徑不存在，則創建目標路徑
Directory.CreateDirectory(Path.GetDirectoryName(sTarget));
}
//如果目標文件已存在，先將其設為非只讀
SetFileReadOnly(sTarget, false);
File.Copy(sSource, sTarget, bOverride);
//保存后再次設為非只讀
SetFileReadOnly(sTarget, false);
return true;
}
catch (Exception ex)
{
errorMessage = ex.Message;
return false;
}
}
public static bool SetFileReadOnly(string sPath, bool bReadOnly)
{
if (File.Exists(sPath) == false)
{
return false;
}
try
{
FileInfo fileInfo = new FileInfo(sPath);
if (fileInfo.Attributes.ToString().IndexOf("ReadOnly") != -1)
fileInfo.Attributes = bReadOnly ? FileAttributes.ReadOnly : FileAttributes.Normal;
}
catch (Exception ex)
{
return false;
}
return true;
}
}
}