一起學(xué)習(xí)MySQL源碼筆記之偷窺線程
安裝完Mysql后,使用VS打開源碼開開眼,我嘞個去,這代碼和想象中怎么差別這么大呢?感覺代碼有些凌亂,注釋代碼都寫的比較隨意,好像沒有什么統(tǒng)一的規(guī)范,不同的文件中代碼風(fēng)格也有差異,可能Mysql經(jīng)過了很多牛人的手之后,集眾牛人之長吧。也可能是我見識比較淺薄,適應(yīng)了自己的代碼風(fēng)格,井底之蛙了,總之還是懷著敬畏的心情開始咱的源碼之旅吧。本人菜鳥,大神輕拍。
Mysql可以啟動起來了,應(yīng)該怎么學(xué)習(xí)呢?總不能從main開始一步一步的看吧,Mysql作為比較底層的大型軟件,涉及到數(shù)據(jù)庫實現(xiàn)的方方面面,沒有厚實的數(shù)據(jù)庫理論基礎(chǔ)和對Mysql各個模塊相當(dāng)?shù)氖煜?,從main開始勢必會把自己引入某個死胡同啊,什么都看,最后啥也不會,咱傷不起。
經(jīng)過思考后,我想還是通過客戶端來調(diào)試服務(wù)器,從而學(xué)習(xí)服務(wù)器代碼比較現(xiàn)實。也就是通過客戶端的動作,看服務(wù)器的反應(yīng)。比如從客戶端的登錄動作來看SERVER如何進(jìn)行通信、用戶識別、鑒定以及任務(wù)分配的,通過CREATE TABLE,來看SERVER如何解析DDL語句以及針對不同的存儲引擎采取的不同的物理存儲方式,通過INSERT語句,來看SERVER如何進(jìn)行Btree的操作。通過SELECT語句來看如何進(jìn)行SQL語句語法樹的創(chuàng)建和優(yōu)化的,通過ROLL BACK,來看SERVER事務(wù)是如何實現(xiàn)的。這里主要是通過跟蹤代碼學(xué)習(xí)Mysql數(shù)據(jù)庫實現(xiàn)的思想,對于具體的代碼不去做過多的追究(主要是我對C++不是很熟悉),好讀書,不求甚解,呵呵。
由此,暫時準(zhǔn)備了以下幾條SQL語句,來有針對的進(jìn)行SERVER的分析
- 1、LOGIN(登錄)
- mysql.exe –uroot –p
- 2、DDL(建表語句)
- create table tb_myisam(c1 int, c2 varchar(256)) engine = myisam;
- create table tb_innodb(c1 int, c2 varchar(256)) engine = innodb;
- 3、INSERT
- Insert into tb_myisam values(1 , ’寂寞的肥肉’);
- Insert into tb_innodb values(1 , ’寂寞的肥肉’);
- 4、SELECT
- Select c1 from tb_myisam;
- Select * from tb_innodb;
- 5、ROLLBACK
大家都知道,mysql可以通過多個客戶端,進(jìn)行并發(fā)操作,當(dāng)然也包括登錄了。在別人登錄的時候,其他的用戶可能正在進(jìn)行一些其它的操作,因此對于登錄我們猜測應(yīng)該有專門的線程負(fù)責(zé)客戶端和服務(wù)器的連接的創(chuàng)建,以保證登錄的及時性,對于每個連接的用戶,應(yīng)該用一個獨立的線程進(jìn)行任務(wù)的執(zhí)行。
首先介紹下mysql中創(chuàng)建線程的函數(shù),創(chuàng)建線程的函數(shù)貌似就是_begin_thread,CreateThread,我們通過VS在整個解決方案中進(jìn)行查找,bingo!在my_winthread.c中找到了調(diào)用_begin_thread的函數(shù)pthread_create,在os0thread.c中找到了調(diào)用CreateThread的函數(shù)os_thread_create,一個系統(tǒng)怎么封裝兩個系統(tǒng)函數(shù)呢??再仔細(xì)看下,發(fā)現(xiàn)my_winthread.c是在項目mysys下,而os0thread.c是在項目innobase下。innobase??!這不就是innodb的插件式存儲引擎么,原來這是存儲引擎自己的封裝的底層函數(shù),哥心中豁然開朗了。我想Mysql應(yīng)用范圍如此之廣,除了開源之外,插件式的存儲引擎功不可沒啊,用戶可以根據(jù)自己的實際應(yīng)用采取不同的存儲引擎,對于大公司,估計會開發(fā)自己的存儲引擎。
下面分析下pthread_create是如何調(diào)用_begin_thread的,先粗略看下源碼。
- int pthread_create(pthread_t *thread_id, pthread_attr_t *attr,
- pthread_handler func, void *param)
- {
- HANDLE hThread;
- struct pthread_map *map;
- DBUG_ENTER("pthread_create");
- if (!(map=malloc(sizeof(*map))))
- DBUG_RETURN(-1);
- map->func=func;
- map->param=param;
- pthread_mutex_lock(&THR_LOCK_thread);
- #ifdef __BORLANDC__
- hThread=(HANDLE)_beginthread((void(_USERENTRY *)(void *)) pthread_start,
- attr->dwStackSize ? attr->dwStackSize :
- 65535, (void*) map);
- #else
- hThread=(HANDLE)_beginthread((void( __cdecl *)(void *)) pthread_start,
- attr->dwStackSize ? attr->dwStackSize :
- 65535, (void*) map);
- #endif
- DBUG_PRINT("info", ("hThread=%lu",(long) hThread));
- *thread_id=map->pthreadself=hThread;
- pthread_mutex_unlock(&THR_LOCK_thread);
- if (hThread == (HANDLE) -1)
- {
- int error=errno;
- DBUG_PRINT("error",
- ("Can't create thread to handle request (error %d)",error));
- DBUG_RETURN(error ? error : -1);
- }
- VOID(SetThreadPriority(hThread, attr->priority)) ;
- DBUG_RETURN(0);
- }
關(guān)鍵的代碼是下面三句:
- map->func=func;
- map->param=param;
- _beginthread((void( __cdecl *)(void *)) pthread_start,
- attr->dwStackSize ? attr->dwStackSize :
- 65535, (void*) map);
從這可以看出,創(chuàng)建的新線程的名字是個固定的函數(shù)——pthread_start,而我們傳進(jìn)來的想創(chuàng)建的函數(shù)func是掛載在了map上了,函數(shù)的參數(shù)同樣的掛載在map上了,這樣我們就可以推理出在pthread_start函數(shù)中,肯定會出現(xiàn)這樣的代碼:
- map->func(map->param);
mysql沒有選擇直接_beginthread(func, stack_size, param)的形式,而是進(jìn)行了一次封裝,不知道這樣的好處是什么,可能牛人的思想不是我這樣小菜鳥能頓悟的,跑題了~~
至此,我們只在pthread_create函數(shù)上設(shè)置斷點,調(diào)試啟動mysqld,斷點停下來,看下系統(tǒng)的線程狀況:
我們第一次進(jìn)入pthread_create,任何線程都沒開始創(chuàng)建呢,按理說系統(tǒng)線程應(yīng)該就只有一個主線程,可現(xiàn)在多了這么多,這些應(yīng)該是innodb存儲引擎創(chuàng)建的線程了(具體是在plugin_init)。根據(jù)線程的名稱,結(jié)合注釋,猜測了下這些線程的作用。
Io_handler_thread:從名稱可以知道這些是I/O線程,負(fù)責(zé)進(jìn)行磁盤I/O。
Svr_error_monitor_thread:應(yīng)該是服務(wù)器出錯監(jiān)控線程。
Svr_lock_timeout_thread:應(yīng)該是和上鎖相關(guān)的線程。
Svr_master_thread:
/*************************************************************************
The master thread controlling the server. */
服務(wù)器控制線程,應(yīng)該是具體進(jìn)行作業(yè)的線程。
Svr_monitor_thread:
/*************************************************************************
A thread prints the info output by various InnoDB monitors. */
監(jiān)控線程,負(fù)責(zé)打印信息。
淡然飄過吧,不去細(xì)究了,我們只關(guān)心pthread_create創(chuàng)建的線程。根據(jù)調(diào)試,發(fā)現(xiàn)多了幾個線程同名的線程_threadstart,如下所示:
調(diào)試時看堆??梢灾肋@三個線程的創(chuàng)建者和作用,如下所示
創(chuàng)建者 | 處理函數(shù) |
create_shutdown_thread | handle_shutdown |
start_handle_manager | handle_manager |
handle_connections_methods | handle_connections_sockets |
創(chuàng)建者:調(diào)用pthread_create進(jìn)行創(chuàng)建線程的函數(shù)。
處理函數(shù):調(diào)用pthread_create所創(chuàng)建的線程的具體的線程函數(shù)。
由名稱我們就可以看出,handle_connections_sockets應(yīng)該是處理連接的線程了,從順序上看,也應(yīng)該是這樣,只有系統(tǒng)中所有的其他必須的線程創(chuàng)建完畢后,才能創(chuàng)建監(jiān)聽線程(連接線程),即監(jiān)聽線程應(yīng)該是系統(tǒng)最后創(chuàng)建的。
找到了我們LOGIN需要的線程了,下次針對這個線程,分析下如何進(jìn)行登錄的,以及登錄后為用戶分配哪些資源。時間不早啦,洗洗睡了
原文鏈接:http://www.cnblogs.com/nocode/archive/2011/04/21/2024330.html
【編輯推薦】