论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2003-12-16 17:44 |只看该作者 |倒序浏览

<html xmlns:v="urn:schemas-microsoft-com:vml"
xmlns

="urn:schemas-microsoft-com

ffice

ffice"
xmlns:w="urn:schemas-microsoft-com

ffice:word"
xmlns="http://www.w3.org/TR/REC-html40">;

<head>;
<meta http-equiv=Content-Type content="text/html; charset=GB2312">;
<meta name=ProgId content=Word.Document>;
<meta name=Generator content="Microsoft Word 9">;
<meta name=Originator content="Microsoft Word 9">;
<link rel=File-List href="./用Proc.files/filelist.xml">;
<link rel=Edit-Time-Data href="./用Proc.files/editdata.mso">;
;
<title>;用Proc*C开发多线程应用程序</title>;
<!--[if gte mso 9]>;<xml>;
<o

ocumentProperties>;
 <o:Author>;BAIJIANFENG</o:Author>;
 <o:LastAuthor>;BAIJIANFENG</o:LastAuthor>;
 <o:Revision>;2</o:Revision>;
 <o:TotalTime>;315</o:TotalTime>;
 <o:Created>;2003-12-16T09:30:00Z</o:Created>;
 <o:LastSaved>;2003-12-16T09:30:00Z</o:LastSaved>;
 <o

ages>;6</o

ages>;
 <o:Words>;623</o:Words>;
 <o:Characters>;3556</o:Characters>;
 <o:Lines>;29</o:Lines>;
 <o

aragraphs>;7</o

aragraphs>;
<o:CharactersWithSpaces>;4367</o:CharactersWithSpaces>;
<o:Version>;9.2812</o:Version>;
</o

ocumentProperties>;
</xml>;<![endif]-->;<!--[if gte mso 9]>;<xml>;
<w:WordDocument>;
<w

unctuationKerning/>;
<w

rawingGridVerticalSpacing>;7.8 磅</w

rawingGridVerticalSpacing>;
<w

isplayHorizontalDrawingGridEvery>;0</w

isplayHorizontalDrawingGridEvery>;
<w

isplayVerticalDrawingGridEvery>;2</w

isplayVerticalDrawingGridEvery>;
<w:Compatibility>;
<w:SpaceForUL/>;
<w:BalanceSingleByteDoubleByteWidth/>;
<w

oNotLeaveBackslashAlone/>;
<w:ULTrailSpace/>;
<w

oNotExpandShiftReturn/>;
<w:AdjustLineHeightInTable/>;
<w:UseFELayout/>;
</w:Compatibility>;
</w:WordDocument>;
</xml>;<![endif]-->;
<style>;
;
</style>;
;;
</head>;

<body lang=ZH-CN style='tab-interval:21.0pt;text-justify-trim:punctuation'>;

<div class=Section1 style='layout-grid:15.6pt'>;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;用;

ro*C;;开发多线程应用程序;;<o:p>;</o:p>;;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;（注：本文来自;

ro*C/C++ Precompiler Programmer's Guide Release
8.1.5;;）;;<o:p>;</o:p>;;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;如果你的操作系统不支持线程，本文暂不适合你。本文包含以下几个部分：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;什么是多线程？;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;

ro*C;;中的运行时上下文;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;运行时上下文的使用模式;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;多线程应用程序的用户接口;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;多线程例子;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;<![if !supportLists]>;;一．;<![endif]>;;什么是多线程？;;

;;一个多线程的应用程序中，线程运行在共享的地址空间里。线程是在进程内部执行的“轻量”级子进程，它们共享代码段和数据段，但是有自己的程序计数器、寄存器和堆栈。全局变量和静态变量在线程之间是共享的，因此通常需要在程序中使用某种互斥机制来管理线程对这些变量的访问，互斥体;;Mutexes;;就是用来保证数据完整性的同步装置。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;有关互斥体的更多讨论，参看多线程编程方面的文章。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;

roc*C;;编译器通过以下方式支持开发多线程的;;Oracle;;应用程序;;(;;在支持线程的平台上;

;;：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;用一个命令行编译选项来产生线程安全的代码;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;用内嵌的;;SQL;;语句和指令支持多线程;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;线程安全的;;Lib;;库和其他客户端;;Lib;;库;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;注意：也许你的平台支持某个特殊的线程包，但还是需要查看;;Oracle;;有关平台的文档，看看;;Oracle;;是否支持它。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;<![if !supportLists]>;;二．;<![endif]>;

ro*C;;中的运行时上下文;;

;;为了在线程和数据库连接之间建立松散的结合，;

ro*C;;引入了一个概念;;runtime_context;;，我们称之为运行时上下文。一个运行时上下文包含了以下资源和信息：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;与数据库服务器的连接;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;当前连接上使用的游标;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;内嵌的一些选项，如;;MODE;;，;;HOLD_CURSOR;;，;;RELEASE_CURSOR;;和;; SELECT_ERROR;;

;;不仅仅是简单的支持线程和连接之间的松散结合，;

ro*C;;编译器还允许开发人员在线程和运行时上下文之间建立松散的结合，;

ro*C;;允许在程序里为运行时上下文定义一个句柄，通过这个句柄，运行时上下文可以在线程之间切换。;;

;;例如，一个交互式应用程序创建了线程;;T1;;，来执行一个查询，并且返回了前;;10;;条记录，然后;;T1;;终止。在用户输入了必须的数据之后，程序又创建了线程;;T2;;，并且把;;T1;;使用的运行时上下文传给;;T2;;，这样;;T2;;可以在同一个游标上获取接下来;;10;;条的记录。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;<![if !supportLists]>;;三．;<![endif]>;;运行时上下文的使用模式;;

;;下面是在多线程的;

ro*C;;程序中使用运行时上下文的两种可能模式：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;多线程共享单个运行时上下文;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;多线程使用互相独立的运行时上下文;;

;;不管采用哪种模式，不能在同一时刻多个线程共享同一个运行时上下文。如果两个或两个以上的线程在同一时刻试图使用同一个运行时上下文，将会出现以下错误：;;SQL-02131:;& ;Runtime
context in use;;。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;1;;．多线程共享单个运行时上下文;;

;;图（一）展示了一个运行在多线程环境中的应用程序，多个线程共享一个运行时上下文来执行;;SQL;;语句，运行时上下文不能在同一时刻被多个线程使用，图中的;;Mutex;;展示了如何防止这种并行使用。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;;<![if !vml]>;<img width=408 height=456
src="./用Proc.files/image001.gif" v:shapes="_x0000_i1025">;<![endif]>;;;

;;图（一）;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;2;;．多线程使用互相独立的运行时上下文;;

;;图（二）展示了使用多个运行时上下文的多线程应用程序，在这种情况下，程序不需要使用互斥锁;;Mutex;;，因为每个线程拥有一个独立的运行时上下文。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;;<![if !vml]>;<img width=408 height=567
src="./用Proc.files/image002.gif" v:shapes="_x0000_i1026">;<![endif]>;;;

;;图（二）;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;<![if !supportLists]>;;四．;<![endif]>;;多线程应用程序的用户接口;;

;

ro*C;;编译器提供以下接口来支持多线程：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;命令行选项，;;THREADS=YES|NO;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;内嵌;;SQL;;语句和指令;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;线程安全的公共库函数;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;1;;．;;THREADS;;选项;;

;;在;;proc;;预编译命令行上指定;;THREADS=YES;;，;;Pro*C;;编译器将保证产生的;;C;;代码是线程安全的。如果指定了;;THREADS=YES;;，;;Pro*C;;将会检查每个包含;;SQL;;执行语句的函数，是否指定了这些语句是在哪个运行时上下文中执行的，若没有发现这类指定标识，编译器就会返回错误。;;

;;2;;．内嵌;;SQL;;语句和指令;;

;;下列内嵌的;;SQL;;语句和指令用于支持多线程和运行时上下文的使用：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL ENABLE THREADS;;；;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL CONTEXT ALLOCATE :;;context_var;;;;；;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL CONTEXT USE {:;;context_var/DEFAULT};;;;;；;;;

;<![if !supportLists]>;;;n;&&&&&&&&
;;;<![endif]>;;EXEC SQL CONTEXT FREE :;;context_var;;;;;；;;;;<o:p>;</o:p>;;;;

;;在以上;;SQL;;语句中，;;;context_var;;;;是运行时上下文句柄，它必须被定义成;;;;sql_context;;;;类型：如;;;;sql_context
context_var;;;;；;;;;<o:p>;</o:p>;;;;

;;使用;;DEFAULT;;意味着接下来的;;SQL;;语句将使用默认的全局运行时上下文，直到另一条;;CONTEXT USE;;语句覆盖它。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL ENABLE THREADS;;

;;这条可执行;;SQL;;语句初始化支持多线程的进程。它必须是程序中第一条可执行的;;SQL;;语句。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL CONTEXT ALLOCATE;;

;;这条可执行;;SQL;;语句分配并初始化了一块用于指向一个新的运行时上下文的内存，并返回标识该上下文的句柄变量，该变量必须声明为;;sql_context;;类型。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL CONTEXT USE;;

;;这条指令性语句告诉编译器接下去执行的;;SQL;;语句将使用指定的运行时上下文，这里的运行时上下文必须在此前已经用;;CONTEXT ALLOCATE;;分配并初始化。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;EXEC SQL CONTEXT FREE;;

;;这条语句释放了运行时上下文句柄指定的内存，并把它设置空值。;;

;;3;;．编程时要考虑的问题;;

;;尽管;;Oracle;;保证;;SQL;;库是线程安全的，但是你还是有责任保证你的;;Pro*C;;代码是为能在多线程下正确运行而设计的，例如，你必须考虑全局变量和静态变量的。;;

;;另外，多线程要求对以下问题进行考虑：;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;把;;sqlca;;结构定义成线程安全的。典型的做法是在每个函数开始定义一个同名的局部变量。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;sqlda;;结构也和;;sqlca;;结构一样处理。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;把程序里的宿主变量定义成线程安全的。也就是说要小心处理程序里的全局变量和静态变量。;;

;<![if !supportLists]>;;n;&&&&&&&&
;;<![endif]>;;避免同一时刻不同线程使用同一个运行时上下文。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;<![if !supportLists]>;;五．;<![endif]>;;多线程例子;;

;;下面的例子运行在;;Red Hat9;;和;;Oracle9;;上。程序目的是用两个线程同时往一个表里插;;10000;;条记录，每个线程都拥有自己的运行时上下文。;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;#include&stdio.h&;;

;;#include&unistd.h&;;

;;#include&pthread.h&;&&&&& ;/* Linux;;线程库头文件;; */;;

;;#include
&sqlca.h&;&&&&&&&&& ;/*
Oracle;;头文件;; */;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;#define SQLCODE
sqlca.sqlcode;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;static int
insert_data( sql_context );;;

;;static int
start();;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;int;;

;;main();;

;;{;;

;;;&&& ;pthread_t tid1, tid2;;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;;&&&&&& ;/* ;;创建两个线程;; */;;

;;;&&& ;if( pthread_create(
&tid1,NULL,(void *)start,NULL ) ){;;

;;;&&&&&&&
;printf( &;;创建线程失败;;!\n& );;;

;;;&&&&&&&
;exit(1);;;

;;;&&& ;};;

;;;&&& ;if( pthread_create(
&tid2,NULL,(void *)start,NULL ) ){;;

;;;&&&&&&&
;printf( &;;创建线程失败;;!\n& );;;

;;;&&&&&&&
;exit(1);;;

;;};;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;/* ;;等待线程退出;; */;;

;;;&&& ;if( pthread_join( tid1,NULL
) ){;;

;;;&&&&&&&
;printf( &;;等待线程结束失败;;!\n& );;;

;;;&&&&&&&
;exit(1);;;

;;;&&& ;};;

;;;&&& ;if( pthread_join( tid2,NULL
) ){;;

;;;&&&&&&&
;printf( &;;等待线程结束失败;;!\n& );;;

;;;&&&&&&&
;exit(1);;;

;;;&&& ;};;

;;;&&& ;exit(0);;;

;;};;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;int;;

;;start();;

;;{;;

;;;&&& ;sql_context context;;;

;;;&&& ;struct sqlca sqlca;;&&&&&&&&&&&&&&& ;/*
;;需要在此定义一个局部的;;sqlca
*/;;

;;;&&& ;char uid[] = &dev/888888&;;;

;;<![if !supportEmptyParas]>;&<![endif]>;<o:p>;</o:p>;;;

;;;&&&&&& ;/* ;;以下;;SQL;;语句的执行顺序不能更改;; */;;

;;;&&& ;EXEC SQL ENABLE THREADS;;;

;;;&&& ;EXEC SQL CONTEXT ALLOCATE
:context;;;

;;EXEC SQL CONTEXT USE :context;;;

<p class=MsoNormal style='margin-l

文库|博客

bjf

白手起家

论坛徽章:: 0

2楼 [报告]

发表于 2003-12-16 17:45 |只看该作者

用Pro*C开发多线程应用程序

完了，搞错了，对不起，斑竹赶紧删掉它

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

返回列表

Chinaunix › 论坛 › 数据库技术 › 数据库开发 › 用Pro*C开发多线程应用程序

用Pro*C开发多线程应用程序 [复制链接]

用Pro*C开发多线程应用程序

浏览过的版块