柚子快報(bào)激活碼778899分享：C# 多線程
柚子快報(bào)激活碼778899分享：C# 多線程
欄目總目錄
C# 多線程編程基本概念
1. 線程（Thread）
定義：線程是CPU調(diào)度和分派的基本單位，是進(jìn)程中的一條執(zhí)行路徑。管理：在C#中，可以使用System.Threading.Thread類來創(chuàng)建和管理線程。
2. 進(jìn)程（Process）
定義：進(jìn)程是系統(tǒng)進(jìn)行資源分配和調(diào)度的一個(gè)獨(dú)立單元，是應(yīng)用程序的一次動(dòng)態(tài)執(zhí)行過程。關(guān)系：一個(gè)進(jìn)程可以擁有多個(gè)線程，這些線程共享進(jìn)程的地址空間和系統(tǒng)資源。
3. 并發(fā)與并行
并發(fā)（Concurrency）：兩個(gè)或多個(gè)任務(wù)在同一時(shí)間段內(nèi)交替執(zhí)行，但不一定在同一時(shí)刻執(zhí)行。并行（Parallelism）：兩個(gè)或多個(gè)任務(wù)在同一時(shí)刻同時(shí)執(zhí)行，通常需要多個(gè)處理器核心。
4. 線程同步與互斥
目的：確保多個(gè)線程安全地訪問共享資源。機(jī)制：鎖（Locks）、互斥量（Mutexes）、信號(hào)量（Semaphores）、監(jiān)視器（Monitors）、條件變量（Condition Variables）等。
5. Task 與 Task Parallel Library (TPL)
Task：代表一個(gè)異步操作，提供靈活的方式來編寫異步代碼。TPL：提供豐富的API支持并行編程，如Parallel.For、Parallel.ForEach等。
6. Async/Await
引入：C# 5.0 引入，基于任務(wù)的異步編程模式。特點(diǎn)：使異步代碼看起來像同步代碼，不會(huì)阻塞調(diào)用線程。
7. 線程池（Thread Pool）
定義：基于池化技術(shù)的線程管理方式，減少線程創(chuàng)建和銷毀的開銷。使用：通過System.Threading.ThreadPool類訪問。
8. 上下文切換
定義：CPU從一個(gè)線程切換到另一個(gè)線程的過程。影響：上下文切換是昂貴的操作，會(huì)消耗CPU時(shí)間并可能導(dǎo)致緩存失效。
9. 死鎖與活鎖
死鎖（Deadlock）：兩個(gè)或多個(gè)線程相互等待對(duì)方釋放資源而無法繼續(xù)執(zhí)行?；铈i（Livelock）：線程不斷嘗試執(zhí)行操作但無法成功，通常由于錯(cuò)誤的同步策略導(dǎo)致。
10. 線程安全
定義：多線程執(zhí)行時(shí)，程序的執(zhí)行結(jié)果符合預(yù)期，不受并發(fā)執(zhí)行的影響。實(shí)現(xiàn)：通過同步機(jī)制、無鎖算法或線程局部變量來減少共享資源的依賴。
線程同步
1. lock 關(guān)鍵字
lock 關(guān)鍵字用于確保一次只有一個(gè)線程可以執(zhí)行某個(gè)代碼塊。它通常用于保護(hù)共享資源或代碼段。
private readonly object lockObject = new object();
public void Method()
{
lock (lockObject)
{
// 訪問或修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 進(jìn)入鎖");
// 模擬長(zhǎng)時(shí)間操作
Thread.Sleep(1000);
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 離開鎖");
}
}
2. Monitor 類
Monitor 類提供了與 lock 關(guān)鍵字類似的功能，但提供了更多的靈活性，如嘗試獲取鎖、釋放鎖等。
private readonly object lockObject = new object();
public void Method()
{
bool lockTaken = false;
try
{
Monitor.TryEnter(lockObject, 1000, ref lockTaken);
if (lockTaken)
{
// 訪問或修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 獲取鎖");
Thread.Sleep(1000);
}
else
{
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 未能獲取鎖");
}
}
finally
{
if (lockTaken)
{
Monitor.Exit(lockObject);
}
}
}
3. Mutex 類
Mutex 是一種跨進(jìn)程的同步基元，但也可以用于同一進(jìn)程內(nèi)的線程同步。
private static Mutex mutex = new Mutex();
public static void Method()
{
mutex.WaitOne();
try
{
// 訪問或修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 進(jìn)入 Mutex");
Thread.Sleep(1000);
}
finally
{
mutex.ReleaseMutex();
}
}
4. Semaphore 類
Semaphore 用于控制對(duì)共享資源的并發(fā)訪問數(shù)量。
private static Semaphore semaphore = new Semaphore(1, 1); // 允許一個(gè)線程訪問
public void Method()
{
semaphore.WaitOne();
try
{
// 訪問或修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 進(jìn)入 Semaphore");
Thread.Sleep(1000);
}
finally
{
semaphore.Release();
}
}
5. Interlocked 類
Interlocked 類提供了一組靜態(tài)方法，用于對(duì)變量執(zhí)行簡(jiǎn)單的原子操作，如遞增、遞減、比較并交換等。
private int counter = 0;
public void Increment()
{
Interlocked.Increment(ref counter);
}
public void PrintCounter()
{
Console.WriteLine("Counter: " + Interlocked.Read(ref counter));
}
6. ReaderWriterLockSlim 類
ReaderWriterLockSlim 允許多個(gè)線程同時(shí)讀取共享資源，但寫入操作是獨(dú)占的。
private ReaderWriterLockSlim rwLock = new ReaderWriterLockSlim();
public void Read()
{
rwLock.EnterReadLock();
try
{
// 讀取共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 正在讀取");
Thread.Sleep(1000);
}
finally
{
rwLock.ExitReadLock();
}
}
public void Write()
{
rwLock.EnterWriteLock();
try
{
// 修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 正在寫入");
Thread.Sleep(1000);
}
finally
{
rwLock.ExitWriteLock();
}
}
7. SpinLock 類
SpinLock 是一種低延遲的鎖，適用于預(yù)計(jì)鎖持有時(shí)間非常短的場(chǎng)景。它會(huì)讓等待鎖的線程進(jìn)行“自旋”，即在一個(gè)循環(huán)中重復(fù)檢查鎖是否可用，而不是將線程掛起。這減少了線程上下文切換的開銷，但也可能增加CPU的使用率。
private SpinLock spinLock = new SpinLock();
public void Method()
{
bool lockTaken = false;
try
{
spinLock.Enter(ref lockTaken);
if (lockTaken)
{
// 訪問或修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 進(jìn)入 SpinLock");
Thread.Sleep(100); // 假設(shè)這是一個(gè)非?？斓牟僮?/p>
}
}
finally
{
if (lockTaken)
{
spinLock.Exit();
}
}
}
8. SemaphoreSlim 類
SemaphoreSlim 是 Semaphore 的一個(gè)輕量級(jí)版本，專為等待時(shí)間較短的場(chǎng)景設(shè)計(jì)。它提供了異步等待的能力，非常適合在基于任務(wù)的異步編程模式（TAP）中使用。
private SemaphoreSlim semaphoreSlim = new SemaphoreSlim(1); // 允許一個(gè)線程同時(shí)訪問
public async Task MethodAsync()
{
await semaphoreSlim.WaitAsync();
try
{
// 訪問或修改共享資源
Console.WriteLine("線程 " + Thread.CurrentThread.ManagedThreadId + " 進(jìn)入 SemaphoreSlim");
await Task.Delay(1000); // 模擬異步操作
}
finally
{
semaphoreSlim.Release();
}
}
9. Barrier 類
Barrier 用于在并行算法中同步線程，確保所有線程都到達(dá)某個(gè)公共屏障點(diǎn)之后才能繼續(xù)執(zhí)行。這對(duì)于需要將任務(wù)分解為多個(gè)階段，并且每個(gè)階段都需要所有線程完成后才能繼續(xù)的場(chǎng)景很有用。
private Barrier barrier = new Barrier(3); // 假設(shè)有三個(gè)線程
public void ThreadMethod(int threadId)
{
Console.WriteLine($"線程 {threadId} 到達(dá)屏障 1");
barrier.SignalAndWait(); // 所有線程都必須調(diào)用這個(gè)方法來等待其他線程
// 執(zhí)行一些工作
Console.WriteLine($"線程 {threadId} 完成工作");
// 可以在屏障上設(shè)置回調(diào)，當(dāng)所有線程都到達(dá)時(shí)執(zhí)行
barrier.PostPhaseAction += (b) =>
{
Console.WriteLine("所有線程都到達(dá)屏障 1，繼續(xù)執(zhí)行...");
};
// 假設(shè)還有一個(gè)屏障點(diǎn)
Console.WriteLine($"線程 {threadId} 到達(dá)屏障 2");
barrier.SignalAndWait();
}
注意：上面的 Barrier 示例中，由于 Barrier 的構(gòu)造函數(shù)只定義了參與者的數(shù)量，并沒有實(shí)際的“屏障點(diǎn)”概念（除了初始化時(shí)的那一次）。在實(shí)際應(yīng)用中，你可能需要多次調(diào)用 SignalAndWait 來表示不同的同步點(diǎn)。此外，PostPhaseAction 回調(diào)是在每個(gè)階段的所有線程都調(diào)用 SignalAndWait 后執(zhí)行的。
10. CountdownEvent 類
CountdownEvent 允許一個(gè)或多個(gè)線程等待直到一組操作中的指定數(shù)量完成。它對(duì)于等待多個(gè)并行任務(wù)完成并繼續(xù)執(zhí)行下一個(gè)任務(wù)的場(chǎng)景非常有用。
private CountdownEvent countdownEvent = new CountdownEvent(3); // 初始化為3，表示有3個(gè)任務(wù)需要完成
public void TaskMethod(int taskId)
{
// 執(zhí)行一些工作
Console.WriteLine($"任務(wù) {taskId} 開始執(zhí)行");
Thread.Sleep(1000); // 模擬耗時(shí)操作
// 任務(wù)完成，信號(hào)量減一
countdownEvent.Signal();
Console.WriteLine($"任務(wù) {taskId} 完成");
}
public void StartTasks()
{
for (int i = 1; i <= 3; i++)
{
Task.Run(() => TaskMethod(i));
}
// 等待所有任務(wù)完成
countdownEvent.Wait();
Console.WriteLine("所有任務(wù)完成");
}
并發(fā)編程最佳實(shí)踐與優(yōu)化
在并發(fā)編程中，有效地管理線程和同步機(jī)制是確保程序性能、穩(wěn)定性和可擴(kuò)展性的關(guān)鍵。以下是并發(fā)編程中的一些最佳實(shí)踐、優(yōu)化策略以及重要考量因素，旨在幫助您構(gòu)建高效且可靠的并發(fā)系統(tǒng)。
1. 并發(fā)集合的使用
優(yōu)勢(shì)：System.Collections.Concurrent 命名空間提供了一系列線程安全的集合類，如 ConcurrentDictionary
2. 優(yōu)化鎖的使用
減少鎖的粒度：通過鎖定盡可能小的數(shù)據(jù)范圍來減少線程等待時(shí)間。使用讀寫鎖（ReaderWriterLockSlim）：對(duì)于讀多寫少的場(chǎng)景，讀寫鎖可以顯著提高性能，因?yàn)樗试S多個(gè)讀操作同時(shí)進(jìn)行，而寫操作會(huì)獨(dú)占訪問權(quán)。避免長(zhǎng)時(shí)間持有鎖：只在必要時(shí)持有鎖，并在操作完成后盡快釋放，以減少對(duì)其他線程的阻塞。
3. 避免死鎖
鎖定順序：確保所有線程以相同的順序獲取鎖，以預(yù)防死鎖的發(fā)生。避免嵌套鎖：減少鎖的嵌套使用，簡(jiǎn)化鎖的依賴關(guān)系。使用超時(shí)：在嘗試獲取鎖時(shí)設(shè)置超時(shí)時(shí)間，避免無限期等待。
4. 異步編程（async 和 await）
提高響應(yīng)性：async 和 await 使得異步操作看起來和同步操作一樣簡(jiǎn)單，允許在等待異步操作時(shí)釋放線程，從而提高應(yīng)用程序的響應(yīng)性和吞吐量。注意：在異步方法中訪問共享資源時(shí)，仍需使用適當(dāng)?shù)耐綑C(jī)制來保護(hù)數(shù)據(jù)一致性。
5. 性能考量
線程開銷：合理控制線程數(shù)量，避免過多線程導(dǎo)致的上下文切換開銷。資源競(jìng)爭(zhēng)：通過優(yōu)化鎖的使用和減少共享資源來降低資源競(jìng)爭(zhēng)。
6. 異常處理
確保健壯性：在并發(fā)環(huán)境中，每個(gè)線程都應(yīng)能妥善處理異常，避免異常傳播導(dǎo)致整個(gè)進(jìn)程崩潰。
7. 調(diào)試與監(jiān)控
調(diào)試技巧：使用斷點(diǎn)、日志記錄和并發(fā)可視化工具等調(diào)試多線程程序。性能分析工具：利用Visual Studio的性能分析器來識(shí)別線程同步相關(guān)的瓶頸，并優(yōu)化性能。并發(fā)可視化：借助并發(fā)可視化工具理解線程間的交互和潛在的并發(fā)問題。
8. 最佳實(shí)踐
最小化共享狀態(tài)：減少線程之間的共享數(shù)據(jù)量，降低同步的復(fù)雜性和開銷。避免共享可變狀態(tài)：盡量使用不可變對(duì)象或確保對(duì)象在創(chuàng)建后不再更改。使用消息傳遞：通過消息傳遞機(jī)制實(shí)現(xiàn)線程間的通信，減少直接共享狀態(tài)的需要。
9. 謹(jǐn)慎使用線程池
合理配置：根據(jù)實(shí)際情況配置線程池的大小，避免資源耗盡和性能下降。任務(wù)調(diào)度：合理使用 Task 和 TaskScheduler 進(jìn)行任務(wù)的調(diào)度和管理。
異步編程模式
極大地簡(jiǎn)化了異步代碼的編寫和理解，使得開發(fā)者能夠以類似于同步代碼的方式來編寫異步邏輯，而無需深入底層的線程管理或回調(diào)機(jī)制。async 和 await 關(guān)鍵字是 C# 5.0 引入的兩個(gè)非常重要的關(guān)鍵字，它們一起工作，使得異步編程變得簡(jiǎn)單和直觀。
async 關(guān)鍵字
async 關(guān)鍵字用于標(biāo)記一個(gè)方法、lambda 表達(dá)式、匿名方法或局部方法作為異步方法。這告訴編譯器該方法內(nèi)部可以使用 await 關(guān)鍵字。異步方法會(huì)隱式返回一個(gè) Task 或 Task
await 關(guān)鍵字
await 關(guān)鍵字用于等待異步操作的完成。它只能用在被 async 修飾的方法內(nèi)部。當(dāng)編譯器看到 await 表達(dá)式時(shí)，它會(huì)將方法的其余部分安排在 await 表達(dá)式表示的異步操作完成后繼續(xù)執(zhí)行。在等待期間，控制權(quán)會(huì)返回給方法的調(diào)用者，允許調(diào)用者繼續(xù)執(zhí)行其他操作，而不是阻塞等待異步操作的完成。await 表達(dá)式的結(jié)果是異步操作的結(jié)果。如果操作返回 Task
示例
下面是一個(gè)簡(jiǎn)單的異步方法示例，該方法使用 HttpClient 異步獲取網(wǎng)頁的內(nèi)容：
using System;
using System.Net.Http;
using System.Threading.Tasks;
class Program
{
static async Task Main(string[] args)
{
string content = await GetWebPageAsync("https://www.example.com");
Console.WriteLine(content);
}
static async Task
{
using (HttpClient client = new HttpClient())
{
HttpResponseMessage response = await client.GetAsync(url);
if (response.IsSuccessStatusCode)
{
return await response.Content.ReadAsStringAsync();
}
else
{
throw new HttpRequestException($"Status code does not indicate success: {response.StatusCode}");
}
}
}
}
在這個(gè)示例中，Main 方法被標(biāo)記為 async，這允許它內(nèi)部使用 await。GetWebPageAsync 方法是另一個(gè)異步方法，它使用 HttpClient 的 GetAsync 方法來異步獲取網(wǎng)頁，并使用 await 等待操作完成。然后，它讀取響應(yīng)內(nèi)容并返回。注意，異常處理也是異步編程中的一個(gè)重要方面，上述示例展示了如何在異步方法中拋出和捕獲異常。
高效異步
在.NET Core（或現(xiàn)在更常見的.NET 5/6/7等）中實(shí)現(xiàn)高效的異步操作主要依賴于理解異步編程模式，特別是如何正確使用async和await關(guān)鍵字，以及理解異步操作背后的線程和任務(wù)的管理。以下是一些實(shí)現(xiàn)高效異步操作的關(guān)鍵點(diǎn)：
1. 理解async和await
使用async修飾方法：這表示該方法是異步的，并允許在方法內(nèi)部使用await。使用await等待異步操作：這會(huì)導(dǎo)致當(dāng)前方法的執(zhí)行暫停，并在異步操作完成時(shí)恢復(fù)。重要的是要等待那些真正需要等待的操作，避免不必要的await調(diào)用，因?yàn)檫@會(huì)增加延遲。
2. 避免阻塞調(diào)用
在異步方法中，應(yīng)避免使用.Result或.Wait()來等待另一個(gè)異步操作的結(jié)果，因?yàn)檫@會(huì)導(dǎo)致死鎖，并破壞異步方法的優(yōu)勢(shì)。使用await來等待異步操作完成，并讓線程池來管理線程。
3. 并行與并發(fā)
并行處理：使用Task.WhenAll來并行執(zhí)行多個(gè)不相互依賴的異步操作，這可以顯著提高性能，特別是當(dāng)這些操作是I/O密集型時(shí)。并發(fā)控制：在需要時(shí)使用SemaphoreSlim或async鎖（如Mutex的異步版本）來控制對(duì)共享資源的并發(fā)訪問。
4. 異步資源管理
使用using語句或async版本的IDisposable接口（如果可用）來確保異步操作中的資源被正確釋放。注意，在async方法中，using語句仍然有效，但Dispose方法將在等待的異步操作完成后調(diào)用。
5. 避免不必要的異步
如果一個(gè)操作本身很快，并且是CPU密集型的，那么將其包裝為異步可能不會(huì)帶來性能上的好處，反而可能因?yàn)轭~外的開銷（如任務(wù)調(diào)度和上下文切換）而降低性能。
6. 性能測(cè)試與調(diào)優(yōu)
使用性能測(cè)試工具（如BenchmarkDotNet）來測(cè)量和比較不同異步實(shí)現(xiàn)的性能。根據(jù)測(cè)試結(jié)果進(jìn)行調(diào)優(yōu)，比如優(yōu)化數(shù)據(jù)訪問模式、減少不必要的異步調(diào)用或改進(jìn)算法。
7. 使用合適的異步API
盡量使用.NET Core提供的異步API，如HttpClient、FileStream的異步方法等，這些API已經(jīng)過優(yōu)化，可以提供更好的性能。如果需要，可以自己實(shí)現(xiàn)異步方法，但要確保正確管理線程和任務(wù)。
8. 監(jiān)控和日志記錄
在生產(chǎn)環(huán)境中監(jiān)控異步操作的性能，包括響應(yīng)時(shí)間、吞吐量等關(guān)鍵指標(biāo)。使用日志記錄來跟蹤異步操作的執(zhí)行流程，以便在出現(xiàn)問題時(shí)進(jìn)行調(diào)試和故障排查。
總之，實(shí)現(xiàn)高效的異步操作需要綜合考慮多個(gè)方面，包括正確使用異步編程模式、避免阻塞調(diào)用、優(yōu)化并行與并發(fā)、管理資源、避免不必要的異步以及進(jìn)行性能測(cè)試和調(diào)優(yōu)。
柚子快報(bào)激活碼778899分享：C# 多線程
文章來源
本文內(nèi)容根據(jù)網(wǎng)絡(luò)資料整理，出于傳遞更多信息之目的，不代表金鑰匙跨境贊同其觀點(diǎn)和立場(chǎng)。
轉(zhuǎn)載請(qǐng)注明，如有侵權(quán)，聯(lián)系刪除。
Tospinomall跨境樂購行
