pthread線程的終止退出 | 線程的大量創建


線程終止的三種方式:

1. 線程只是從啟動例程中返回,返回值是線程的退出碼;

2. 線程調用了pthread_exit函數;

3. 線程可以被同一進程中的其他線程取消。

**************************************************************

轉載自:http://hi.baidu.com/ganss/blog/item/ff7799f97a87de58242df24c.html

1 線程取消的定義

一般情況下,線程在其主體函數退出的時候會自動終止,但同時也可以因為接收到另一個線程發來的終止(取消)請求而強制終止。

2 線程取消的語義

1. 線程取消的方法是向目標線程發Cancel信號,但如何處理Cancel信號則由目標線程自己決定,或者忽略(當禁止取消時)、或者立即終止(當在取消點或異步模式下)、或者繼續運行至Cancelation-point(取消點,下面將描述),總之由不同的Cancelation狀態決定。

2. 線程接收到CANCEL信號的缺省處理(即pthread_create()創建線程的缺省狀態)是繼續運行至取消點再處理(退出),或在異步方式下直接退出。一個線程處理cancel請求的退出操作相當於pthread_exit(PTHREAD_CANCELED)。當然線程可以通過設置為PTHREAD_CANCEL_DISABLE來拒絕處理cancel請求,稍后會提及。

3. 線程的取消與線程的工作方式(joinable或detached)無關。

3 取消點

根據POSIX標准,pthread_join()、pthread_testcancel()、pthread_cond_wait()、 pthread_cond_timedwait()、sem_wait()、sigwait()等函數以及read()、write()等會引起阻塞的系統調用都是Cancelation-point,而其他pthread函數都不會引起Cancelation動作。但是pthread_cancel的手冊頁聲稱,由於LinuxThread庫與C庫結合得不好,因而目前C庫函數都不是Cancelation-point;但CANCEL信號會使線程從阻塞的系統調用中退出,並置EINTR錯誤碼,因此可以在需要作為Cancelation-point的系統調用前后調用pthread_testcancel(),從而達到POSIX標准所要求的目標,即如下代碼段:  
pthread_testcancel();  
retcode = read(fd, buffer,length);  
pthread_testcancel();

使用前 須判斷線程ID的有效性!即判斷並保證:thrd != 0 否則有可能會出現“段錯誤”的異常!

但是pthread_cancel的手冊頁聲稱,由於LinuxThread庫與C庫結合得不好,因而目前C庫函數(比如read())在linux中都不是Cancelation-point;但CANCEL信號會使線程從阻塞的系統調用中退出,並置EINTR錯誤碼,因此可以在需要作為Cancelation-point的系統調用前后調用 pthread_testcancel(),從而達到POSIX標准所要求的目標,即如下代碼段:

 pthread_testcancel();
retcode = read(fd, buffer, length);
pthread_testcancel();

 

4 程序設計方面的考慮

1. 如果線程處於無限循環中,且循環體內沒有執行至取消點的必然路徑,則線程無法由外部其他線程的取消請求而終止。因此在這樣的循環體的必經路徑上應該加入pthread_testcancel()調用

2. 當pthread_cancel()返回時,線程未必已經取消,可能僅僅將請求發送給目標線程,而目標線程目前沒有到達取消點,如果要知道線程在何時中止,就需要在取消它之后調用pthread_join()。有一個例外是當線程被detach后,不能這樣處理:
a) 當join一個已經detached的線程時,返回EINVAL
b) 如果join后該線程設置為detached,則detach將不起作用。
因此,如果知道一個線程可能會以分離方式運行,就不需要在pthread_cancel()后調用pthread_join()

5 與線程取消相關的pthread函數

int pthread_cancel(pthread_t thread)
發送終止信號給thread線程,如果成功則返回0,否則為非0值。發送成功並不意味着thread會終止。

int pthread_setcancelstate(int state, int *oldstate)
設置本線程對Cancel信號的反應,state有兩種值:PTHREAD_CANCEL_ENABLE(缺省)和 PTHREAD_CANCEL_DISABLE,分別表示收到信號后設為CANCLED狀態和忽略CANCEL信號繼續運行;old_state如果不為NULL則存入原來的Cancel狀態以便恢復。

int pthread_setcanceltype(int type, int *oldtype)
設置本線程取消動作的執行時機,type有兩種取值:PTHREAD_CANCEL_DEFFERED 和 PTHREAD_CANCEL_ASYCHRONOUS,僅當Cancel狀態為Enable時有效,分別表示收到信號后繼續運行至下一個取消點再退出和立即執行取消動作(退出);oldtype如果不為NULL則存入運來的取消動作類型值。

void pthread_testcancel(void)
檢查本線程是否處於Canceld狀態,如果是,則進行取消動作,否則直接返回。

6 檢測一個線程是否還活着的pthread函數

int pthread_kill(pthread_t thread, int sig)
向指定ID的線程發送sig信號,如果線程的代碼內不做任何信號處理,則會按照信號默認的行為影響整個進程。也就是說,如果你給一個線程發送了SIGQUIT,但線程卻沒有實現signal處理函數,則整個進程退出。
pthread_kill(threadid, SIGKILL)也一樣,他會殺死整個進程。
如果要獲得正確的行為,就需要在線程內實現signal(SIGKILL,sig_handler)。
所以,如果int sig的參數不是0,那一定要清楚到底要干什么,而且一定要實現線程的信號處理函數,否則,就會影響整個進程。
那么,如果int sig的參數是0呢,這是一個保留信號,一個作用就是用來判斷線程是不是還活着。
我們來看一下pthread_kill的返回值:
線程仍然活着:0
線程已不存在:ESRCH
信號不合法:EINVAL

***************************************************************************

先看下面一段程序:

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>
void* func(void *)

  pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL); //允許退出線程 
  pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL); //設置立即取消 
  while (1) 
  { 
    //操作 ; 
  } 
  return NULL;
}
int main(int argc, char *argv[])

  pthread_t thrd; 
  pthread_attr_t attr; 
  pthread_attr_init(&attr); 
  pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); 
  if( pthread_create(&thrd, &attr, func, NULL) ) 
  { 
    perror( "pthread_create error "); 
    exit(EXIT_FAILURE); 
   } 
   if( !pthread_cancel(thrd) )  
   { 
     printf( "pthread_cancel OK\n " ); 
   } 
   sleep( 10 ); 
   return 0;
}
上面程序並不會將子線程取消 why?

-------

因為沒有遇見或是設置引起Cancelation動作的取消點,

可以在調用了pthread_cancel函數后,調用pthread_join函數以獲得取消點,使線程退出。

***************************************************************************

再看下面一段程序:

pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
pthread_testcancel();/*the thread can be killed only here*/
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);

這個是代碼里面摘錄下來的代碼,什么情況下 線程能被殺掉呢?
因為 這段代碼 在 線程的循環里面,那每次執行到這段的時候,為什么都沒有被殺掉呢?

-------

簡單理解就是,兩個線程T1和T2,如果T1發送cancel信號給T2,則T2默認會在取消點退出。取消點是固定的地方,只要thread_join()、pthread_testcancel()、pthread_cond_wait()、 pthread_cond_timedwait()、sem_wait()、sigwait()等函數以及read()、write()等會引起阻塞的系統調用都是Cancelation-point。

假設T2在一個循環中,這個循環中沒有取消點,那么怎么辦?收到cancel信號也沒辦法退出。這時就用pthread_testcancel()來創造一個取消點,如果有cancel信號就退出,沒有就繼續運行。

那么pthread_setcancelstate就比較好理解了,就是設置T2的狀態,PTHREAD_CANCEL_ENABLE就是正常處理cancel信號,PTHREAD_CANCEL_DISABLE就是忽略cancel信號。

那么循環體中每次執行到這段的時候,為什么都沒有被殺掉呢?
這里的被殺死指的是別的線程發送cancel信號給他,也許這里根本就沒發送所以沒被殺死。

====================================================================================

使用pthread_create創建大量線程時,創建線程失敗,Resource temporarily unavailable的解決辦法

轉載自:http://blog.csdn.net/lifuxianoa/article/details/6796813   http://blog.csdn.net/lifuxianoa/article/details/6797104 

今天在一個測試程序中使用pthread_create創建了大量線程,但是如果線程數量增加到400后,就會出現線程創建失敗,perror打印出的錯誤原因是:Resource temporarily unavailable。

在網上查了下,原因如下,Linux系統中每個線程都擁有獨立的棧空間,而我的系統上調用ulimit -a看到的結果如下:

ulimit -a
core file size (blocks, -c) 0
data seg size (kbytes, -d) unlimited
scheduling priority (-e) 20
file size (blocks, -f) unlimited
pending signals (-i) 16382
max locked memory (kbytes, -l) 64
max memory size (kbytes, -m) unlimited
open files (-n) 1024
pipe size (512 bytes, -p) 8
POSIX message queues (bytes, -q) 819200
real-time priority (-r) 0
stack size (kbytes, -s) 8192
cpu time (seconds, -t) unlimited
max user processes (-u) unlimited
virtual memory (kbytes, -v) unlimited
file locks (-x) unlimited

可以看到stack size是8M, 400個線程就需要8*400=3200M,虛擬內存不夠用。

解決辦法有兩種:

1.使用ulimit -s 1024*1024命令,將線程棧大小臨時設置成1M,經過試驗能同時創建2000個線程了。

2.使用pthread_attr_setstacksize在程序中改變線程棧大小。

====================================================================================
 進程與線程

轉載自:http://blog.sina.com.cn/s/blog_68f262210100j61q.html

通俗的解釋

一個系統運行着很多進程,可以比喻為一條馬路上有很多馬車

不同的進程可以理解為不同的馬車

而同一輛馬車可以有很多匹馬來拉----這些馬就是線程

假設道路的寬度恰好可以通過一輛馬車

道路可以認為是臨界資源

那么馬車成為分配資源的最小單位(進程)

而同一個馬車被很多匹馬驅動(線程)----即最小的運行單位

每輛馬車馬匹數>=1

所以馬匹數=1的時候進程和線程沒有嚴格界限,只存在一個概念上的區分度

馬匹數>1的時候才可以嚴格區分進程和線程

專業的解釋:

簡而言之,一個程序至少有一個進程,一個進程至少有一個線程.

線程的划分尺度小於進程,使得多線程程序的並發性高。另外,進程在執行過程中擁有獨立的內存單元,而多個線程共享內存,從而極大地提高了程序的運行效率。

線程在執行過程中與進程還是有區別的。每個獨立的線程有一個程序運行的入口、順序執行序列和程序的出口。但是線程不能夠獨立執行,必須依存在應用程序中,由應用程序提供多個線程執行控制。

從邏輯角度來看,多線程的意義在於一個應用程序中,有多個執行部分可以同時執行。但操作系統並沒有將多個線程看做多個獨立的應用,來實現進程的調度和管理以及資源分配。這就是進程和線程的重要區別。

進程是具有一定獨立功能的程序關於某個數據集合上的一次運行活動,進程是系統進行資源分配和調度的一個獨立單位.

線程是進程的一個實體,是CPU調度和分派的基本單位,它是比進程更小的能獨立運行的基本單位.線程自己基本上不擁有系統資源,只擁有一點在運行中必不可少的資源(如程序計數器,一組寄存器和棧),但是它可與同屬一個進程的其他的線程共享進程所擁有的全部資源.

一個線程可以創建和撤銷另一個線程;同一個進程中的多個線程之間可以並發執行

進程和線程的主要差別在於它們是不同的操作系統資源管理方式。進程有獨立的地址空間,一個進程崩潰后,在保護模式下不會對其它進程產生影響,而線程只是一個進程中的不同執行路徑。線程有自己的堆棧和局部變量,但線程之間沒有單獨的地址空間,一個線程死掉就等於整個進程死掉,所以多進程的程序要比多線程的程序健壯,但在進程切換時,耗費資源較大,效率要差一些。但對於一些要求同時進行並且又要共享某些變量的並發操作,只能用線程,不能用進程。如果有興趣深入的話,我建議你們看看《現代操作系統》或者《操作系統的設計與實現》。對就個問題說得比較清楚。

+++++++++++++++++++++++++++++++++++++++++++++++

進程概念

  進程是表示資源分配的基本單位,又是調度運行的基本單位。例如,用戶運行自己的程序,系統就創建一個進程,並為它分配資源,包括各種表格、內存空間、磁盤空間、I/O設備等。然后,把該進程放人進程的就緒隊列。進程調度程序選中它,為它分配CPU以及其它有關資源,該進程才真正運行。所以,進程是系統中的並發執行的單位。

  在Mac、Windows NT等采用微內核結構的操作系統中,進程的功能發生了變化:它只是資源分配的單位,而不再是調度運行的單位。在微內核系統中,真正調度運行的基本單位是線程。因此,實現並發功能的單位是線程。

線程概念

  線程是進程中執行運算的最小單位,亦即執行處理機調度的基本單位。如果把進程理解為在邏輯上操作系統所完成的任務,那么線程表示完成該任務的許多可能的子任務之一。例如,假設用戶啟動了一個窗口中的數據庫應用程序,操作系統就將對數據庫的調用表示為一個進程。假設用戶要從數據庫中產生一份工資單報表,並傳到一個文件中,這是一個子任務;在產生工資單報表的過程中,用戶又可以輸人數據庫查詢請求,這又是一個子任務。這樣,操作系統則把每一個請求――工資單報表和新輸人的數據查詢表示為數據庫進程中的獨立的線程。線程可以在處理器上獨立調度執行,這樣,在多處理器環境下就允許幾個線程各自在單獨處理器上進行。操作系統提供線程就是為了方便而有效地實現這種並發性

引入線程的好處

1)易於調度。

2)提高並發性。通過線程可方便有效地實現並發性。進程可創建多個線程來執行同一程序的不同部分。

3)開銷少。創建線程比創建進程要快,所需開銷很少。。

4)利於充分發揮多處理器的功能。通過創建多線程進程(即一個進程可具有兩個或更多個線程),每個線程在一個處理器上運行,從而實現應用程序的並發性,使每個處理器都得到充分運行。

++++++++++++++++++++++++++++++++++++++++++++++++

進程和線程的關系:

1)一個線程只能屬於一個進程,而一個進程可以有多個線程,但至少有一個線程。

2)資源分配給進程,同一進程的所有線程共享該進程的所有資源。

3)處理機分給線程,即真正在處理機上運行的是線程。

4)線程在執行過程中,需要協作同步。不同進程的線程間要利用消息通信的辦法實現同步。

線程是指進程內的一個執行單元,也是進程內的可調度實體.

與進程的區別:

(1)調度:線程作為調度和分配的基本單位,進程作為擁有資源的基本單位

(2)並發性:不僅進程之間可以並發執行,同一個進程的多個線程之間也可並發執行

(3)擁有資源:進程是擁有資源的一個獨立單位,線程不擁有系統資源,但可以訪問隸屬於進程的資源.

(4)系統開銷:在創建或撤消進程時,由於系統都要為之分配和回收資源,導致系統的開銷明顯大於創建或撤消線程時的開銷。

+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

進程間的通信方式:

1.管道(pipe)及有名管道(named pipe):

管道可用於具有親緣關系的父子進程間的通信,有名管道除了具有管道所具有的功能外,它還允許無親緣關系進程間的通信。

2.信號(signal):

信號是在軟件層次上對中斷機制的一種模擬,它是比較復雜的通信方式,用於通知進程有某事件發生,一個進程收到一個信號與處理器收到一個中斷請求效果上可以說是一致的。

3.消息隊列(message queue):

消息隊列是消息的鏈接表,它克服了上兩種通信方式中信號量有限的缺點,具有寫權限得進程可以按照一定得規則向消息隊列中添加新信息;對消息隊列有讀權限得進程則可以從消息隊列中讀取信息。

4.共享內存(shared memory):

可以說這是最有用的進程間通信方式。它使得多個進程可以訪問同一塊內存空間,不同進程可以及時看到對方進程中對共享內存中數據得更新。這種方式需要依靠某種同步操作,如互斥鎖和信號量等。

5.信號量(semaphore):

主要作為進程之間及同一種進程的不同線程之間得同步和互斥手段。

6.套接字(socket);

這是一種更為一般得進程間通信機制,它可用於網絡中不同機器之間的進程間通信,應用非常廣泛。

++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

線程之間的同步通信:

1.信號量 二進制信號量 互斥信號量 整數型信號量記錄型信號量

2.消息 消息隊列 消息郵箱

3.事件event

互斥型信號量:必須是同一個任務申請,同一個任務釋放,其他任務釋放無效。同一個任務可以遞歸申請。(互斥信號量是二進制信號量的一個子集

 

 

二進制信號量:一個任務申請成功后,可以由另一個任務釋放。(與互斥信號量的區別

整數型信號量:取值不局限於0和1,可以一個任務申請,另一個任務釋放。(包含二進制信號量,二進制信號量是整數型信號量的子集

二進制信號量實現任務互斥:

打印機資源只有一個,a b c三個任務共享,當a取得使用權后,為了防止其他任務錯誤地釋放了信號量(二進制信號量允許其他任務釋放),必須將打印機房的門關起來(進入臨界段),用完后,釋放信號量,再把門打開(出臨界段),其他任務再進去打印。(而互斥型信號量由於必須由取得信號量的那個任務釋放,故不會出現其他任務錯誤地釋放了信號量的情況出現,故不需要有臨界段。互斥型信號量是二進制信號量的子集。)

二進制信號量實現任務同步:

a任務一直等待信號量,b任務定時釋放信號量,完成同步功能

記錄型信號量(record semaphore)
每個信號量s除一個整數值value(計數)外,還有一個等待隊列List,其中是阻塞在該信號量的各個線程的標識。當信號量被釋放一個,值被加一后,系統自動從等待隊列中喚醒一個等待中的線程,讓其獲得信號量,同時信號量再減一。

+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

同步和互斥的區別:

當有多個線程的時候,經常需要去同步這些線程以訪問同一個數據或資源。例如,假設有一個程序,其中一個線程用於把文件讀到內存,而另一個線程用於統計文件中的字符數。當然,在把整個文件調入內存之前,統計它的計數是沒有意義的。但是,由於每個操作都有自己的線程,操作系統會把兩個線程當作是互不相干的任務分別執行,這樣就可能在沒有把整個文件裝入內存時統計字數。為解決此問題,你必須使兩個線程同步工作。

所謂互斥,是指散布在不同進程之間的若干程序片斷,當某個進程運行其中一個程序片段時,其它進程就不能運行它們之中的任一程序片段,只能等到該進程運行完這個程序片段后才可以運行。如果用對資源的訪問來定義的話,互斥某一資源同時只允許一個訪問者對其進行訪問,具有唯一性和排它性。但互斥無法限制訪問者對資源的訪問順序,即訪問是無序的

所謂同步,是指散步在不同進程之間的若干程序片斷,它們的運行必須嚴格按照規定的某種先后次序來運行,這種先后次序依賴於要完成的特定的任務。如果用對資源的訪問來定義的話,同步是指在互斥的基礎上(大多數情況),通過其它機制實現訪問者對資源的有序訪問。在大多數情況下,同步已經實現了互斥,特別是所有寫入資源的情況必定是互斥的。少數情況是指可以允許多個訪問者同時訪問資源。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM