第淺談C#多線程下的調(diào)優(yōu)//并行編程

Console.WriteLine($"并行編程開始，主線程Id:{Thread.CurrentThread.ManagedThreadId}");

Console.WriteLine("【示例1】");

//示例1：

//一次性執(zhí)行1個(gè)或多個(gè)線程，效果類似：TaskWaitAll，只不過Parallel的主線程也參與了計(jì)算

Parallel.Invoke(

()={DoSomething("并行1-1");},

()={DoSomething("并行1-2");},

()={DoSomething("并行1-3");},

()={DoSomething("并行1-4");},

()={DoSomething("并行1-5");});

Console.WriteLine("*************并行結(jié)束************");

Console.ReadLine();

}

執(zhí)行Test1結(jié)果：

示例2：

publicstaticvoidTest2()

//并行編程

Console.WriteLine($"并行編程開始，主線程Id:{Thread.CurrentThread.ManagedThreadId}");

Console.WriteLine("【示例2】");

//示例2：

//定義要執(zhí)行的線程數(shù)量

Parallel.For(0,5,t=

inta=t;

DoSomething($"并行2-{a}");

Console.WriteLine("*************并行結(jié)束************");

Console.ReadLine();

}

結(jié)果：

示例3：

publicstaticvoidTest3()

//并行編程

Console.WriteLine($"并行編程開始，主線程Id:{Thread.CurrentThread.ManagedThreadId}");

Console.WriteLine("【示例3】");

ParallelOptionsoptions=newParallelOptions()

MaxDegreeOfParallelism=3//執(zhí)行線程的最大并發(fā)數(shù)量,執(zhí)行完成一個(gè)，就接著開啟一個(gè)

//遍歷集合，根據(jù)集合數(shù)量執(zhí)行線程數(shù)量

Parallel.ForEach(newListstring{"a","b","c","d","e","f","g"},options,(t,status)=

//status.Break();//這一次結(jié)束。

//status.Stop();//整個(gè)Parallel結(jié)束掉，Break和Stop不可以共存

DoSomething($"并行4-{t}");

}

結(jié)果：分成3次并行

五、異步IO

1.異步IO于同步IO比較

異步IO在數(shù)據(jù)準(zhǔn)備階段不會阻塞主線程，而同步IO則會阻塞主線程。

2.異步讀寫文件

這里使用FileStream類，它帶有一個(gè)參數(shù)useAsync，可以避免在許多情況下阻塞線程池的線程?？梢酝ㄟ^useAsync=true來進(jìn)行啟用或在構(gòu)造函數(shù)中進(jìn)行參數(shù)調(diào)用。

但是我們不能對StreamReader和StreamWriter中的參數(shù)進(jìn)行設(shè)置。但是，如果你想使用該參數(shù)useAsync，則需要自己新建一個(gè)FileStream對象。

請注意，異步調(diào)用是在UI中的，即使線程池線程阻塞，在await期間，用戶界面線程也不會被阻塞。

異步寫入文本

///summary

///異步寫入文件

////summary

///returns/returns

publicasyncTaskWriteTextAsync()

varpath="temp.txt";//文件名

varcontent=Guid.NewGuid().ToString();//寫入內(nèi)容

using(varfs=newFileStream(path,FileMode.OpenOrCreate,FileAccess.ReadWrite,FileShare.None,bufferSize:4096,useAsync:true))

varbuffer=Encoding.UTF8.GetBytes(content);

awaitfs.WriteAsync(buffer,0,buffer.Length);

}

執(zhí)行完查看根目錄文件結(jié)果：

異步讀取文件

///summary

///異步讀取文本

////summary

///returns/returns

publicstaticasyncTaskReadTextAsync()

varfileName="temp.txt";//文件名

using(varfs=newFileStream(fileName,

FileMode.OpenOrCreate,FileAccess.Read,FileShare.None,bufferSize:4096,useAsync:true))

varsb=newStringBuilder();

varbuffer=newbyte[4096];

varreadLength=0;

while((readLength=awaitfs.ReadAsync(buffer,0,buffer.Length))!=0)

vartext=Encoding.UTF8.GetString(buffer,0,readLength);

sb.Append(text);