（注：本文來(lái)自Pro*C/C++ Precompiler Programmer's Guide Release 8.1.5）
如果你的操作系統(tǒng)不支持線(xiàn)程，本文暫不適合你。本文包含以下幾個(gè)部分：
n 什么是多線(xiàn)程？
n Pro*C中的運(yùn)行時(shí)上下文
n 運(yùn)行時(shí)上下文的使用模式
n 多線(xiàn)程應(yīng)用程序的用戶(hù)接口
n 多線(xiàn)程例子
一．什么是多線(xiàn)程？
一個(gè)多線(xiàn)程的應(yīng)用程序中，線(xiàn)程運(yùn)行在共享的地址空間里。線(xiàn)程是在進(jìn)程內(nèi)部執(zhí)行的“輕量”級(jí)子進(jìn)程，它們共享代碼段和數(shù)據(jù)段，但是有自己的程序計(jì)數(shù)器、寄存器和堆棧。全局變量和靜態(tài)變量在線(xiàn)程之間是共享的，因此通常需要在程序中使用某種互斥機(jī)制來(lái)管理線(xiàn)程對(duì)這些變量的訪(fǎng)問(wèn)，互斥體Mutexes就是用來(lái)保證數(shù)據(jù)完整性的同步裝置。
有關(guān)互斥體的更多討論，參看多線(xiàn)程編程方面的文章。
Proc*C編譯器通過(guò)以下方式支持開(kāi)發(fā)多線(xiàn)程的Oracle應(yīng)用程序(在支持線(xiàn)程的平臺(tái)上)：
n 用一個(gè)命令行編譯選項(xiàng)來(lái)產(chǎn)生線(xiàn)程安全的代碼
n 用內(nèi)嵌的SQL語(yǔ)句和指令支持多線(xiàn)程
n 線(xiàn)程安全的Lib庫(kù)和其他客戶(hù)端Lib庫(kù)
注意：也許你的平臺(tái)支持某個(gè)特殊的線(xiàn)程包，但還是需要查看Oracle有關(guān)平臺(tái)的文檔，看看Oracle是否支持它。
二．Pro*C中的運(yùn)行時(shí)上下文
為了在線(xiàn)程和數(shù)據(jù)庫(kù)連接之間建立松散的結(jié)合，Pro*C引入了一個(gè)概念runtime_context，我們稱(chēng)之為運(yùn)行時(shí)上下文。一個(gè)運(yùn)行時(shí)上下文包含了以下資源和信息：
n 與數(shù)據(jù)庫(kù)服務(wù)器的連接
n 當(dāng)前連接上使用的游標(biāo)
n 內(nèi)嵌的一些選項(xiàng)，如MODE，HOLD_CURSOR，RELEASE_CURSOR和 SELECT_ERROR
不僅僅是簡(jiǎn)單的支持線(xiàn)程和連接之間的松散結(jié)合，Pro*C編譯器還允許開(kāi)發(fā)人員在線(xiàn)程和運(yùn)行時(shí)上下文之間建立松散的結(jié)合，Pro*C允許在程序里為運(yùn)行時(shí)上下文定義一個(gè)句柄，通過(guò)這個(gè)句柄，運(yùn)行時(shí)上下文可以在線(xiàn)程之間切換。
例如，一個(gè)交互式應(yīng)用程序創(chuàng)建了線(xiàn)程T1，來(lái)執(zhí)行一個(gè)查詢(xún)，并且返回了前10條記錄，然后T1終止。在用戶(hù)輸入了必須的數(shù)據(jù)之后，程序又創(chuàng)建了線(xiàn)程T2，并且把T1使用的運(yùn)行時(shí)上下文傳給T2，這樣T2可以在同一個(gè)游標(biāo)上獲取接下來(lái)10條的記錄。
三．運(yùn)行時(shí)上下文的使用模式
下面是在多線(xiàn)程的Pro*C程序中使用運(yùn)行時(shí)上下文的兩種可能模式：
n 多線(xiàn)程共享單個(gè)運(yùn)行時(shí)上下文
n 多線(xiàn)程使用互相獨(dú)立的運(yùn)行時(shí)上下文
不管采用哪種模式，不能在同一時(shí)刻多個(gè)線(xiàn)程共享同一個(gè)運(yùn)行時(shí)上下文。如果兩個(gè)或兩個(gè)以上的線(xiàn)程在同一時(shí)刻試圖使用同一個(gè)運(yùn)行時(shí)上下文，將會(huì)出現(xiàn)以下錯(cuò)誤：SQL-02131: Runtime context in use。
1．多線(xiàn)程共享單個(gè)運(yùn)行時(shí)上下文
2．多線(xiàn)程使用互相獨(dú)立的運(yùn)行時(shí)上下文
四．多線(xiàn)程應(yīng)用程序的用戶(hù)接口
Pro*C編譯器提供以下接口來(lái)支持多線(xiàn)程：
n 命令行選項(xiàng)，THREADS=YES|NO
n 內(nèi)嵌SQL語(yǔ)句和指令
n 線(xiàn)程安全的公共庫(kù)函數(shù)
1．THREADS選項(xiàng)
在proc預(yù)編譯命令行上指定THREADS=YES，Pro*C編譯器將保證產(chǎn)生的C代碼是線(xiàn)程安全的。如果指定了THREADS=YES，Pro*C將會(huì)檢查每個(gè)包含SQL執(zhí)行語(yǔ)句的函數(shù)，是否指定了這些語(yǔ)句是在哪個(gè)運(yùn)行時(shí)上下文中執(zhí)行的，若沒(méi)有發(fā)現(xiàn)這類(lèi)指定標(biāo)識(shí)，編譯器就會(huì)返回錯(cuò)誤。
2．內(nèi)嵌SQL語(yǔ)句和指令
下列內(nèi)嵌的SQL語(yǔ)句和指令用于支持多線(xiàn)程和運(yùn)行時(shí)上下文的使用：
n EXEC SQL ENABLE THREADS；
n EXEC SQL CONTEXT ALLOCATE :context_var；
n EXEC SQL CONTEXT USE {:context_var/DEFAULT}；
n EXEC SQL CONTEXT FREE :context_var；
在以上SQL語(yǔ)句中，context_var是運(yùn)行時(shí)上下文句柄，它必須被定義成sql_context類(lèi)型：如sql_context context_var；
使用DEFAULT意味著接下來(lái)的SQL語(yǔ)句將使用默認(rèn)的全局運(yùn)行時(shí)上下文，直到另一條CONTEXT USE語(yǔ)句覆蓋它。
n EXEC SQL ENABLE THREADS
這條可執(zhí)行SQL語(yǔ)句初始化支持多線(xiàn)程的進(jìn)程。它必須是程序中第一條可執(zhí)行的SQL語(yǔ)句。
n EXEC SQL CONTEXT ALLOCATE
這條可執(zhí)行SQL語(yǔ)句分配并初始化了一塊用于指向一個(gè)新的運(yùn)行時(shí)上下文的內(nèi)存，并返回標(biāo)識(shí)該上下文的句柄變量，該變量必須聲明為sql_context類(lèi)型。
n EXEC SQL CONTEXT USE
這條指令性語(yǔ)句告訴編譯器接下去執(zhí)行的SQL語(yǔ)句將使用指定的運(yùn)行時(shí)上下文，這里的運(yùn)行時(shí)上下文必須在此前已經(jīng)用CONTEXT ALLOCATE分配并初始化。
n EXEC SQL CONTEXT FREE
這條語(yǔ)句釋放了運(yùn)行時(shí)上下文句柄指定的內(nèi)存，并把它設(shè)置空值。
3．編程時(shí)要考慮的問(wèn)題
盡管Oracle保證SQL庫(kù)是線(xiàn)程安全的，但是你還是有責(zé)任保證你的Pro*C代碼是為能在多線(xiàn)程下正確運(yùn)行而設(shè)計(jì)的，例如，你必須考慮全局變量和靜態(tài)變量的。
另外，多線(xiàn)程要求對(duì)以下問(wèn)題進(jìn)行考慮：
n 把sqlca結(jié)構(gòu)定義成線(xiàn)程安全的。典型的做法是在每個(gè)函數(shù)開(kāi)始定義一個(gè)同名的局部變量。
n sqlda結(jié)構(gòu)也和sqlca結(jié)構(gòu)一樣處理。
n 把程序里的宿主變量定義成線(xiàn)程安全的。也就是說(shuō)要小心處理程序里的全局變量和靜態(tài)變量。
n 避免同一時(shí)刻不同線(xiàn)程使用同一個(gè)運(yùn)行時(shí)上下文。
五．多線(xiàn)程例子
下面的例子運(yùn)行在Red Hat9和Oracle9上。程序目的是用兩個(gè)線(xiàn)程同時(shí)往一個(gè)表里插10000條記錄，每個(gè)線(xiàn)程都擁有自己的運(yùn)行時(shí)上下文。
#include
#include
#include /* Linux線(xiàn)程
頭文件 */
#include "sqlca.h" /* Oracle頭文件 */
#define SQLCODE sqlca.sqlcode
static int insert_data( sql_context );
static int start();
int
main()
{
pthread_t tid1, tid2;
/* 創(chuàng)建兩個(gè)線(xiàn)程 */
if( pthread_create( &tid1,NULL,(void *)start,NULL ) ){
printf( "創(chuàng)建線(xiàn)程失敗!\n" );
exit(1);
}
if( pthread_create( &tid2,NULL,(void *)start,NULL ) ){
printf( "創(chuàng)建線(xiàn)程失敗!\n" );
exit(1);
}
/* 等待線(xiàn)程退出 */
if( pthread_join( tid1,NULL ) ){
printf( "等待線(xiàn)程結(jié)束失敗!\n" );
exit(1);
}
if( pthread_join( tid2,NULL ) ){
printf( "等待線(xiàn)程結(jié)束失敗!\n" );
exit(1);
}
exit(0);
}
int
start()
{
sql_context context;
struct sqlca sqlca; /* 需要在此定義一個(gè)局部的sqlca */
char uid[] = "dev/888888";
/* 以下SQL語(yǔ)句的執(zhí)行順序不能更改 */
EXEC SQL ENABLE THREADS;
EXEC SQL CONTEXT ALLOCATE :context;
EXEC SQL CONTEXT USE :context;
EXEC SQL CONNECT :uid;
if( SQLCODE < 0 ){
printf( "創(chuàng)建數(shù)據(jù)庫(kù)連接失敗,%d:%s\n", SQLCODE,sqlca.sqlerrm.sqlerrmc);
return -1;
}insert_data( context );
EXEC SQL COMMIT WORK RELEASE;
if( SQLCODE < 0 ){
printf( "斷開(kāi)數(shù)據(jù)庫(kù)連接失敗!%d:%s\n", SQLCODE,sqlca.sqlerrm.sqlerrmc );
return -1;
}
EXEC SQL CONTEXT FREE :context;
return 0;
}
static int
insert_data( context )
sql_context context;
{
struct sqlca sqlca; /* 需要在此定義一個(gè)局部的sqlca */
char name[11];
int age;
int i;
strcpy( name, "test" );
age = 20;
EXEC SQL CONTEXT USE :context; /* 指定執(zhí)行SQL語(yǔ)句的上下文 */
for( i=0; i