2. 程式人生 > >多執行緒環境下不安全的訊息佇列存取---執行緒不同步會造成隱患

多執行緒環境下不安全的訊息佇列存取---執行緒不同步會造成隱患

阿新 • • 發佈：2019-01-22

        前面， 我們把訊息佇列存取都放在主執行緒中， 而在實際應用中， 很多時候， 存訊息佇列在主執行緒， 取訊息佇列在其他執行緒（如網路執行緒）。 下面， 我們將之前的程式改為多執行緒程式：

#include <windows.h>
#include <iostream>
using namespace std;

#define Rectangle MyRectangle  // 避免Rectangle與Windows中的Rectangle衝突

// 物件的id值
typedef enum
{
	ErrorId = -1,
	IntegerId = 1,
	PointId = 2,
	RectangeId = 3,
}ObjectID;


// 基類
struct Basic
{
	ObjectID id;
	virtual Basic *copy() = 0; // 純虛擬函式
};

// 整數類
struct Integer : public Basic
{
	int a;

	Basic *copy()
	{
		Integer *p = new Integer;
		p->a = ((Integer*)this)->a;
		p->id = ((Integer*)this)->id;

		return p;
	}
};

// 點類
struct Point : public Basic
{
	int x;
	int y;

	Basic *copy()
	{
		Point *p = new Point;
		p->x = ((Point*)this)->x;
		p->y = ((Point*)this)->y;
		p->id = ((Point*)this)->id;

		return p;
	}
};

// 矩形類
struct Rectangle : public Basic
{
	Point point;
	int width;
	int height;

	Basic *copy()
	{
		Rectangle *p = new Rectangle;
		p->point.x = ((Rectangle*)this)->point.x;
		p->point.y = ((Rectangle*)this)->point.y;
		p->width = ((Rectangle*)this)->width;
		p->height = ((Rectangle*)this)->height;
		p->id = ((Rectangle*)this)->id;

		return p;
	}
};

// 抽象物件的共同點， 構造成新的結點， 便於連結
typedef struct node
{
	node *next;
	Basic *pBasic;
}Node;


Node *head = NULL;  // 指向第一結點（採用不帶頭結點的連結串列）


// 往鏈式訊息佇列中塞訊息
Node *addToMsgQueue(Basic* pb)
{
	Node *pn = new Node;
	Node *qn = NULL;
	Basic *p = pb->copy(); // 多型性

	if(NULL == head)
	{
		head = pn;
	}
	else
	{
		qn = head;
		while(NULL != qn->next)
		{
			qn = qn->next;
		}

		qn->next = pn;
	}

	pn->pBasic = p;   // 千萬別忘記啊
	pn->next = NULL;  // 千萬別忘記啊

	return head;
}


// 從鏈式訊息佇列中取出訊息（結點）
Node *getMsgFromQueue()
{
	if(NULL == head)
	{
		return NULL;
	}

	Node *pn = head;
	head = head->next;

	return pn;
} 


// 執行緒函式
DWORD WINAPI ThreadFun(LPVOID pM)
{
	Node *p = NULL;

	// 從訊息佇列中取出訊息
	while(1)
	{
		p = getMsgFromQueue();
		if(NULL == p)
		{
			Sleep(100);
			continue;
		}

		// 對指標進行還原
		switch(p->pBasic->id) 
		{
			case IntegerId:
			{
				cout << ((Integer*)(p->pBasic))->a << endl;
				break;
			}
			case PointId:
			{
			
				cout << ((Point *)(p->pBasic))->x << endl;
				cout << ((Point *)(p->pBasic))->y << endl;
				break;
			}
			case RectangeId:
			{
				cout << ((Rectangle *)(p->pBasic))->point.x << endl;
				cout << ((Rectangle *)(p->pBasic))->point.y << endl;
				cout << ((Rectangle *)(p->pBasic))->width << endl;
				cout << ((Rectangle *)(p->pBasic))->height << endl;
				break;
			}
			default:
			{
				break;
			}
		}
	}

	return 0;
}

// 主執行緒
int main()
{

	HANDLE handle = CreateThread(NULL, 0, ThreadFun, NULL, 0, NULL);
    CloseHandle(handle);

	// 定義三個物件並賦值
	Integer i;
	Point po;
	Rectangle rect;

	i.id = IntegerId;
	po.id = PointId;
	rect.id = RectangeId;
	
	i.a = 11;
	po.x = 22;
	po.y = 33;

	rect.point.x = 44;
	rect.point.y = 55;
	rect.width = 66;
	rect.height = 77;

	// 塞入訊息佇列
	while(1)
	{	
		addToMsgQueue(&i);
		addToMsgQueue(&po);
		addToMsgQueue(&rect);
		Sleep(2000);
	}

	return 0;
}
      結果為：

11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77
11
22
33
44
55
66
77

...

       看似得到了正確的結果， 但是， 上述程式是有問題的， 加入主執行緒正在存， 子執行緒正在取， 那豈不是亂套了麼。 當然， 上面的程式僥倖沒有出現這種情況， 為了說明這種情況， 我在addToMsgQueue函式中， 故意加一個睡眠語句， 再看看：

#include <windows.h>
#include <iostream>
using namespace std;

#define Rectangle MyRectangle  // 避免Rectangle與Windows中的Rectangle衝突

// 物件的id值
typedef enum
{
	ErrorId = -1,
	IntegerId = 1,
	PointId = 2,
	RectangeId = 3,
}ObjectID;


// 基類
struct Basic
{
	ObjectID id;
	virtual Basic *copy() = 0; // 純虛擬函式
};

// 整數類
struct Integer : public Basic
{
	int a;

	Basic *copy()
	{
		Integer *p = new Integer;
		p->a = ((Integer*)this)->a;
		p->id = ((Integer*)this)->id;

		return p;
	}
};

// 點類
struct Point : public Basic
{
	int x;
	int y;

	Basic *copy()
	{
		Point *p = new Point;
		p->x = ((Point*)this)->x;
		p->y = ((Point*)this)->y;
		p->id = ((Point*)this)->id;

		return p;
	}
};

// 矩形類
struct Rectangle : public Basic
{
	Point point;
	int width;
	int height;

	Basic *copy()
	{
		Rectangle *p = new Rectangle;
		p->point.x = ((Rectangle*)this)->point.x;
		p->point.y = ((Rectangle*)this)->point.y;
		p->width = ((Rectangle*)this)->width;
		p->height = ((Rectangle*)this)->height;
		p->id = ((Rectangle*)this)->id;

		return p;
	}
};

// 抽象物件的共同點， 構造成新的結點， 便於連結
typedef struct node
{
	node *next;
	Basic *pBasic;
}Node;


Node *head = NULL;  // 指向第一結點（採用不帶頭結點的連結串列）


// 往鏈式訊息佇列中塞訊息
Node *addToMsgQueue(Basic* pb)
{
	Node *pn = new Node;
	Node *qn = NULL;
	Basic *p = pb->copy(); // 多型性

	if(NULL == head)
	{
		head = pn;
	}
	else
	{
		qn = head;
		while(NULL != qn->next)
		{
			qn = qn->next;
		}

		Sleep(20); // 故意加的語句， 用於構造異常場景 
		qn->next = pn;
	}

	pn->pBasic = p;   // 千萬別忘記啊
	pn->next = NULL;  // 千萬別忘記啊

	return head;
}


// 從鏈式訊息佇列中取出訊息（結點）
Node *getMsgFromQueue()
{
	if(NULL == head)
	{
		return NULL;
	}

	Node *pn = head;
	head = head->next;

	return pn;
} 


// 執行緒函式
DWORD WINAPI ThreadFun(LPVOID pM)
{
	Node *p = NULL;

	// 從訊息佇列中取出訊息
	while(1)
	{
		p = getMsgFromQueue();
		if(NULL == p)
		{
			Sleep(100);
			continue;
		}

		// 對指標進行還原
		switch(p->pBasic->id) 
		{
			case IntegerId:
			{
				cout << ((Integer*)(p->pBasic))->a << endl;
				break;
			}
			case PointId:
			{
			
				cout << ((Point *)(p->pBasic))->x << endl;
				cout << ((Point *)(p->pBasic))->y << endl;
				break;
			}
			case RectangeId:
			{
				cout << ((Rectangle *)(p->pBasic))->point.x << endl;
				cout << ((Rectangle *)(p->pBasic))->point.y << endl;
				cout << ((Rectangle *)(p->pBasic))->width << endl;
				cout << ((Rectangle *)(p->pBasic))->height << endl;
				break;
			}
			default:
			{
				break;
			}
		}
	}

	return 0;
}

// 主執行緒
int main()
{

	HANDLE handle = CreateThread(NULL, 0, ThreadFun, NULL, 0, NULL);
    CloseHandle(handle);

	// 定義三個物件並賦值
	Integer i;
	Point po;
	Rectangle rect;

	i.id = IntegerId;
	po.id = PointId;
	rect.id = RectangeId;
	
	i.a = 11;
	po.x = 22;
	po.y = 33;

	rect.point.x = 44;
	rect.point.y = 55;
	rect.width = 66;
	rect.height = 77;

	// 塞入訊息佇列
	while(1)
	{	
		addToMsgQueue(&i);
		addToMsgQueue(&po);
		addToMsgQueue(&rect);
		Sleep(2000);
	}

	return 0;
}
      程式結果為：

11
44
55
66
77
11
22
33
44
55
66
77
...

      看看，看看， 產生異常了吧， 主要原因是執行緒不同步問題， 在後續博文中， 我們將介紹執行緒安全的情況， 那時， 我們將考慮執行緒同步。





相關推薦

多執行緒環境下不安全的訊息佇列存取---執行緒不同步會造成隱患

        前面， 我們把訊息佇列存取都放在主執行緒中， 而在實際應用中， 很多時候， 存訊息佇列在主執行緒， 取訊息佇列在其他執行緒（如網路執行緒）。 下面， 我們將之前的程式改為多執行緒程式： #include <windows.h> #include

多執行緒環境下安全的訊息佇列存取---利用訊號量

       前面幾篇博文中， 我們一直在討論異質連結串列訊息佇列問題， 在本文中， 我們繼續來探討這一問題， 在多執行緒環境下， 考慮執行緒同步問題， 程式碼如下（我用Sleep(20);來故意搗亂）： #include <windows.h> #inclu

C# Winform專案中多執行緒環境下, 如何跨執行緒對Window窗體控制元件進行安全訪問？

請嘗試執行這段程式碼, 結果你會發現微軟開發工具會提示, Tb_Text.Text = int_Index.ToString(); 涉及"對Windows窗體控制元件進行執行緒安全呼叫", 並給瞭如下的解決方案:https://msdn.microsoft.com/zh-cn/library/ms171728

HashMap多執行緒環境下的死迴圈問題解釋

hashMap在多執行緒環境下，呼叫put方法出現的死迴圈是由於擴容時候resize方法導致的連結串列出現迴圈。 void resize(int newCapacity) { Entry[] oldTable = table; int oldCapacity =

Java多執行緒環境下的懶漢模式解決方案

一、場景簡述 單例模式下有餓漢模式和懶漢模式，其中懶漢模式在於呼叫相關方法時例項才被建立。懶漢模式我們不難實現，但是在懶漢模式下我們如果使用多執行緒，就會取出多個例項的情況，與單例模式相違背，所以該篇部落格筆者主要關於在多執行緒環境下利用DCL雙檢查鎖機制來實現懶漢模式。

linux多執行緒環境下的搶屍行為（system返回-1：No child processes）

#!/usr/bin/env python #coding:utf8 import os import time pid = os.fork() if pid: print 'in parent.sleepin....' while True:

多執行緒環境下呼叫 HttpWebRequest 併發連線限制

.net 的 HttpWebRequest 或者 WebClient 在多執行緒情況下存在併發連線限制，這個限制在桌面作業系統如 windows xp , windows  7 下預設是2，在伺服器作業系統上預設為10. 如果不修改這個併發連線限制，那麼客戶端同時可以建立的

多執行緒環境下的ConcurrentHashMap

文章目錄 什麼是ConcurrentHashMap？ 底層資料結構？ 如何實現併發安全? transfer和ForwardingNode Hash計算 什麼是ConcurrentHashMap？ C

多執行緒環境下使用log4j輸出各執行緒的標識，區分各執行緒輸出的內容

在多執行緒環境下，我們可能需要輸出很多資訊，每個執行緒產生的日誌資訊可能都是類似的，我們如何區分出哪些資訊是同一個執行緒輸出的呢？其實log4j已經提供了多種實現方式： 1.使用PatternLayout，在設定輸出格式的時候增加%t引數，這樣會輸出各個執行緒的執行緒名稱，這樣我們就可以根據執行緒名稱區分哪

從專案中談JAVA中static 方法在多執行緒環境下的運用

最近在做一個實時性比較高的系統，資料庫訪問很頻繁。在這個專案中資料庫訪問的大多數都被我做成了static 方法。(這樣做應該不是很好，沒辦法發揮dao模式的優勢，不過湊合用吧)因這個系統是多執行緒。static方法的運用需要注意，不能在servlet中使用成員變數，因為如果你

java多執行緒環境下對變數的讀寫操作的原子性問題

本文轉載自:http://www.cnblogs.com/qlee/archive/2011/09/13/2174434.html 以下多執行緒對int型變數x的操作，哪幾個需要進行同步：（ ）A. x=y; B. x++; C. ++x; D. x=1;從表面看上去實在

(轉載)多執行緒環境下的Map一定要同步嗎？

原文地址：http://pt.alibaba-inc.com/wp/experience_644/map-multi-threaded-environment-you-must-be-synchronized.html 我們都知道在多執行緒操縱Map時，需要對Map資料結構

多執行緒環境下操作HashMap的問題

HashMap為什麼不是執行緒安全，併發操作Hashmap會帶來什麼問題： 這個問題曾經有一個面試官問過我，當時我天真的以為是讀寫操作併發時存在髒資料的問題，當時面試官不置可否。我後面回來查資料，發現

Android開發之多執行緒環境下更新介面

Android應用程式的介面運行於獨立的執行緒裡。但有時候軟體需要單獨的執行緒來處理資料，然後再更新介面。這樣能夠保證介面執行的流暢又不至於影響使用者體驗。這裡的問題在於，UI只能被介面執行緒更新，在多執行緒環境下回出錯。本文會展示這種典型的錯誤，以及解決方案。 下面以計時

mktime和localtime_r能在多執行緒環境下使用麼？

localtime和mktime是用來在時間分量和時間秒數之間進行轉換的標準c函式。 在glibc的文件描述中，localtime的實現是使用了一個內部靜態快取來儲存結果，所以這是一個不可用於多執行緒環境的api。glibc提供了一個執行緒安全版本localtime_r。mk

Spring多執行緒環境下Bean的管理策略

一、Bean的狀態：stateful 與 stateless 有狀態會話bean：每個使用者有自己特有的一個例項，在使用者的生存期內，bean保持了使用者的資訊，即“有狀態”； 一旦使用者滅亡（呼叫

localtime_r在多執行緒環境下可能存在死鎖

         但是在某些情況下,localtime_r可能存在死鎖的情況,使用如下的測試程式:        #include <pthread.h> #include <time.h>        void *mytest(void *arg) {         pthrea

多執行緒環境下的計數器

下面的例子是通過CAS來實現一個多執行緒環境下的安全計數器 package cn.com.test.vol.p201612; import java.util.concurrent.Executo

多執行緒環境下使用openssl

static cyg_mutex_t *lock_cs;// 多執行緒保護的初始化 // This function allocates and initializes the lock array // and registers the callbacks. This should be called /

Java設計模式（二）：單例模式的5種實現方式，以及在多執行緒環境下5種建立單例模式的效率

這段時間從頭溫習設計模式。記載下來，以便自己複習，也分享給大家。 package com.iter.devbox.singleton; /** * 餓漢式 * @author Shearer * */ public class SingletonDemo1 {