發送來自兩個不同線程的TCP消息

Question

我有兩個線程需要使用相同的已建立連接發送TCP消息。我有一個對象讓我們說tcpSender，我想從展位線程中使用。我如何設計我的軟件以便不會產生併發問題和丟失的消息？

謝謝！

Answer 1

您可以將此模型設置爲生產者/消費者，其中每個線程在準備好時將消息注入到TCPSender中，並且TCPSender維護消息的FIFO隊列。插入到隊列中將被鎖定（在TCPSender內）並按順序處理。

會有另一個線程是消費當隊列不是空的消息鎖定每次消息從隊列中刪除。

兩個直接的好處是你可以支持任意數量的生產者，並且阻塞僅限於插入隊列而不是實際發送消息（從生產者的角度來看）。

Answer 2

您可以創建一個Semaphore，其中每個發送前你acquire和release發送後。這將確保資源一次被一個線程訪問。

Answer 3

如果發送此數據後不需要回答，則可以使用隊列。