建站
咨詢
售后
建站咨詢
新聞中心
一、 線程間通信的方式和實(shí)現(xiàn)
在多線程編程中，線程間通信是非常常見的需求，它指的是多個線程之間通過某種機(jī)制來交換信息，協(xié)調(diào)彼此的行為。線程間通信的方式常用的有以下幾種：
成都創(chuàng)新互聯(lián)公司專注于慶云企業(yè)網(wǎng)站建設(shè),響應(yīng)式網(wǎng)站設(shè)計(jì),商城網(wǎng)站建設(shè)。慶云網(wǎng)站建設(shè)公司,為慶云等地區(qū)提供建站服務(wù)。全流程按需定制開發(fā)，專業(yè)設(shè)計(jì)，全程項(xiàng)目跟蹤，成都創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務(wù)
共享內(nèi)存：線程之間可以通過共享內(nèi)存來交換信息，每個線程擁有對共享內(nèi)存區(qū)域的讀寫權(quán)限。一般情況下需要使用鎖來保證共享內(nèi)存的同步與互斥。
using System.Threading;
class Program {
private static int data = 0;
private static bool isRunning = true;
static void Main(string[] args) {
using (var mutex = new Mutex(false, "sharedMutex"))
using (var mappedFile = MemoryMappedFile.CreateOrOpen("sharedMemory", 1024))
using (var accessor = mappedFile.CreateViewAccessor()) {
var thread1 = new Thread(() => {
while (isRunning) {
mutex.WaitOne();
accessor.Write(0, data);
mutex.ReleaseMutex();
Thread.Sleep(1000);
}
});
var thread2 = new Thread(() => {
while (isRunning) {
mutex.WaitOne();
data = accessor.ReadInt32(0);
mutex.ReleaseMutex();
Console.WriteLine($"Data received: {data}");
Thread.Sleep(1000);
}
});
thread1.Start();
thread2.Start();
Console.WriteLine("Press enter to exit.");
Console.ReadLine();
isRunning = false;
thread1.Join();
thread2.Join();
}
}
}該程序創(chuàng)建了一個名為 sharedMemory 的內(nèi)存映射文件和一個名為 sharedMutex 的互斥對象。兩個線程分別負(fù)責(zé)將數(shù)據(jù)寫入內(nèi)存映射文件和讀取內(nèi)存映射文件中的數(shù)據(jù)。在操作前，需要通過互斥對象進(jìn)行同步與互斥。
消息傳遞：線程之間可以通過發(fā)送消息來交換信息，每個線程擁有一個接收緩沖區(qū)和一個發(fā)送緩沖區(qū)。這里的消息指的是數(shù)據(jù)包或者數(shù)據(jù)流，線程之間通過操作緩沖區(qū)來完成數(shù)據(jù)交換。
using System.Collections.Concurrent;
class Program {
private static bool isRunning = true;
private static BlockingCollection messageQueue = new BlockingCollection();
static void Main(string[] args) {
var thread1 = new Thread(() => {
while (isRunning) {
var message = messageQueue.Take();
Console.WriteLine($"Thread 1 received message: {message}");
}
});
var thread2 = new Thread(() => {
while (isRunning) {
var message = messageQueue.Take();
Console.WriteLine($"Thread 2 received message: {message}");
}
});
thread1.Start();
thread2.Start();
// Simulate sending some messages
messageQueue.Add("Hello from thread 1");
messageQueue.Add("Hello from thread 2");
messageQueue.Add("Hello again from thread 1");
messageQueue.Add("Goodbye from thread 2");
Console.WriteLine("Press enter to exit.");
Console.ReadLine();
isRunning = false;
thread1.Join();
thread2.Join();
}
} 該程序使用 BlockingCollection
管道：線程之間可以通過管道來交換信息，一個線程將數(shù)據(jù)寫入管道，另一個線程則從管道中讀取數(shù)據(jù)。管道本質(zhì)上也是一種共享內(nèi)存的方式，并且會自動進(jìn)行同步(管道的大小是有限制的)
信號量：線程之間可以通過信號量來同步和互斥訪問資源，一個線程獲取信號量后就可以進(jìn)行訪問操作，其他線程則需要等待。信號量可以用于實(shí)現(xiàn)進(jìn)程之間的同步和互斥，但在多線程應(yīng)用中使用時需要注意信號量的實(shí)現(xiàn)。
using System.Threading;
class Program {
private static bool isRunning = true;
private static AutoResetEvent signal = new AutoResetEvent(false);
static void Main(string[] args) {
var thread1 = new Thread(() => {
while (isRunning) {
Console.WriteLine("Thread 1 is waiting...");
signal.WaitOne();
Console.WriteLine("Thread 1 received signal.");
}
});
var thread2 = new Thread(() => {
while (isRunning) {
Console.WriteLine("Thread 2 is waiting...");
signal.WaitOne();
Console.WriteLine("Thread 2 received signal.");
}
});
thread1.Start();
thread2.Start();
// Send signals to the threads
signal.Set(); // signals only one of the waiting threads
signal.Set(); // signals the other waiting thread
Console.WriteLine("Press enter to exit.");
Console.ReadLine();
isRunning = false;
signal.Set(); // unblock any waiting threads
thread1.Join();
thread2.Join();
}
}該程序使用 AutoResetEvent 類來實(shí)現(xiàn)線程間的同步。兩個線程等待信號并進(jìn)行處理，主線程發(fā)送信號來通知等待的線程進(jìn)行處理?？梢允褂?Set() 方法發(fā)送信號并使用 WaitOne() 方法等待信號。
using System.Threading;
class Program {
private static bool isRunning = true;
private static ManualResetEvent signal = new ManualResetEvent(false);
static void Main(string[] args) {
var thread1 = new Thread(() => {
while (isRunning) {
Console.WriteLine("Thread 1 is waiting...");
signal.WaitOne();
Console.WriteLine("Thread 1 received signal.");
signal.Reset(); // reset the signal
}
});
var thread2 = new Thread(() => {
while (isRunning) {
Console.WriteLine("Thread 2 is waiting...");
signal.WaitOne();
Console.WriteLine("Thread 2 received signal.");
signal.Reset(); // reset the signal
}
});
thread1.Start();
thread2.Start();
// Send signals to the threads
signal.Set(); // signals both of the waiting threads
Console.WriteLine("Press enter to exit.");
Console.ReadLine();
isRunning = false;
signal.Set(); // unblock any waiting threads
thread1.Join();
thread2.Join();
}
}該程序使用 ManualResetEvent 類來實(shí)現(xiàn)線程間的同步。兩個線程等待信號并進(jìn)行處理，主線程發(fā)送信號來通知等待的線程進(jìn)行處理。可以使用 Set() 方法發(fā)送信號并使用 WaitOne() 方法等待信號，同時使用 Reset() 方法將信號狀態(tài)重置為未發(fā)出狀態(tài)，以便下次等待。
互斥鎖：線程之間可以通過互斥鎖來同步和互斥訪問共享資源，一個線程獲取鎖后就可以進(jìn)行訪問操作，其他線程則需要等待釋放鎖?；コ怄i是一種經(jīng)典的同步和互斥機(jī)制，在多線程編程中用得比較廣泛，一般和條件變量一起使用。
using System.Threading;
class Program {
private static bool isRunning = true;
private static object lockObject = new object();
private static int counter = 0;
static void Main(string[] args) {
var thread1 = new Thread(() => {
while (isRunning) {
lock (lockObject) {
while (counter % 2 == 1) {
Monitor.Wait(lockObject);
}
Console.WriteLine($"Thread 1: {counter++}");
Monitor.PulseAll(lockObject);
}
}
});
var thread2 = new Thread(() => {
while (isRunning) {
lock (lockObject) {
while (counter % 2 == 0) {
Monitor.Wait(lockObject);
}
Console.WriteLine($"Thread 2: {counter++}");
Monitor.PulseAll(lockObject);
}
}
});
thread1.Start();
thread2.Start();
Console.WriteLine("Press enter to exit.");
Console.ReadLine();
isRunning = false;
thread1.Join();
thread2.Join();
}
}二、同步和異步線程間通信的比較
同步和異步線程間通信的主要區(qū)別在于調(diào)用者是否需要等待被調(diào)用者完成任務(wù)才能繼續(xù)執(zhí)行下一步操作。
同步線程間通信指的是調(diào)用者主動向被調(diào)用者請求一個任務(wù)，并等待被調(diào)用者完成后再繼續(xù)執(zhí)行。這種模式對于簡單的應(yīng)用程序來說很容易實(shí)現(xiàn)，但有時會引發(fā)線程死鎖的問題，因?yàn)槿绻鄠€線程都在等待對方完成任務(wù)，就會形成死循環(huán)。
異步線程間通信則是被調(diào)用者在處理任務(wù)的同時，通知調(diào)用者任務(wù)的狀態(tài)。這種模式可以提高程序的響應(yīng)速度，因?yàn)檎{(diào)用者可以繼續(xù)執(zhí)行其他任務(wù)，而不必等待被調(diào)用者完成任務(wù)才能進(jìn)行下一步操作。
C# 語言提供了多種方式來實(shí)現(xiàn)線程間的同步和異步通信。其中，同步通信可以使用 Mutex、Semaphore 和 Monitor 等互斥量類來實(shí)現(xiàn)線程鎖定和等待，在獲取到資源后再釋放鎖定。異步通信可以使用委托、事件和 Completion 是C# 5.0 開始的異步編程功能，可以使用 async 和 await 關(guān)鍵字來快速實(shí)現(xiàn)異步編程。
三、 多個線程協(xié)作完成任務(wù)
在多線程編程中，有時我們需要多個線程協(xié)作完成一個復(fù)雜的任務(wù)。這些線程需要互相通信、協(xié)調(diào)以達(dá)到同一目標(biāo)。下面是一些常用的多線程協(xié)作技術(shù)：
信號量 Semaphore：Semaphore 可以用來控制某一資源的訪問權(quán)，比如網(wǎng)絡(luò)連接數(shù)限制、數(shù)據(jù)庫連接池等。Semaphore 通過計(jì)數(shù)器來控制資源的數(shù)量，并提供了 Acquire 和 Release 等方法來允許或阻塞線程訪問資源。多個線程可以共享一個 Semaphore，當(dāng) Semaphore 計(jì)數(shù)為 0 時，其他線程就需要等待。
Mutex：Mutex 是一種操作系統(tǒng)提供的同步機(jī)制，它可以保證在同一時刻只有一個線程訪問共享資源。Mutex 提供了 Lock 和 Unlock 等方法來保護(hù)臨界區(qū)。如果一個線程獲得 Mutex，其他線程就必須等待直到該線程釋放 Mutex。
AutoResetEvent 和 ManualResetEvent：這兩種事件用于線程間的同步，AutoResetEvent 的 WaitOne 方法會阻塞當(dāng)前線程直到事件被發(fā)出，發(fā)出后事件重置為未發(fā)出狀態(tài)；ManualResetEvent 則不會自動重置，需要調(diào)用 Reset 方法手動將事件重置為未發(fā)出狀態(tài)。
CountdownEvent：CountdownEvent通常用于多個線程都需要完成某個任務(wù)后才能繼續(xù)執(zhí)行的場景。當(dāng)所有線程都完成任務(wù)后，調(diào)用Done方法通知CountdownEvent，等待的線程就會被喚醒。
本文名稱：多線程編程系列之線程間通信和協(xié)作
網(wǎng)站鏈接：http://m.5511xx.com/article/djhspeo.html
