用ProC开发多线程应用程序

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

（注：本文来自 Pro*C/C++ Precompiler Programmer's Guide Release 8.1.5）

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

n   什么是多线程？

n   Pro*C 中的运行时上下文

n   运行时上下文的使用模式

n   多线程应用程序的用户接口

n   多线程例子

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

n   用一个命令行编译选项来产生线程安全的代码

n   用内嵌的 SQL 语句和指令支持多线程

n   线程安全的 Lib 库和其他客户端 Lib 库

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

看 Oracle 是否支持它。

二．Pro*C 中的运行时上下文

为了在线程和数据库连接之间建立松散的结合，Pro*C 引入了一个概念 runtime_context，我

们称之为运行时上下文。一个运行时上下文包含了以下资源和信息：

n   与数据库服务器的连接

例如，一个交互式应用程序创建了线程 T1，来执行一个查询，并且返回了前 10 条记录，

然后 T1 终止。在用户输入了必须的数据之后，程序又创建了线程 T2，并且把 T1 使用的运

行时上下文传给 T2，这样 T2 可以在同一个游标上获取接下来 10 条的记录。

三．运行时上下文的使用模式

下面是在多线程的 Pro*C 程序中使用运行时上下文的两种可能模式：

n   多线程共享单个运行时上下文

n   多线程使用互相独立的运行时上下文

不管采用哪种模式，不能在同一时刻多个线程共享同一个运行时上下文。如果两个或两个

以上的线程在同一时刻试图使用同一个运行时上下文，将会出现以下错误：SQL-02131:R

untime context in use。

图（二）展示了使用多个运行时上下文的多线程应用程序，在这种情况下，程序不需要使

用互斥锁 Mutex，因为每个线程拥有一个独立的运行时上下文。

图（二）

四．多线程应用程序的用户接口

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

n   命令行选项，THREADS=YES|NO

n   内嵌 SQL 语句和指令

n   线程安全的公共库函数

1．THREADS 选项

在 proc 预编译命令行上指定 THREADS=YES，Pro*C 编译器将保证产生的 C 代码是线程安

n   EXEC SQL CONTEXT ALLOCATE :context_var；

n   EXEC SQL CONTEXT USE {:context_var/DEFAULT}；

n   EXEC SQL CONTEXT FREE :context_var；

在以上 SQL 语句中，context_var 是运行时上下文句柄，它必须被定义成 sql_context 类型：

如 sql_context context_var；

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

CONTEXT USE 语句覆盖它。

n   EXEC SQL ENABLE THREADS

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

句。

n   EXEC SQL CONTEXT FREE

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

3．编程时要考虑的问题

尽管 Oracle 保证 SQL 库是线程安全的，但是你还是有责任保证你的 Pro*C 代码是为能在多

线程下正确运行而设计的，例如，你必须考虑全局变量和静态变量的。

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

n   把 sqlca 结构定义成线程安全的。典型的做法是在每个函数开始定义一个同名的局部

变量。

n   sqlda 结构也和 sqlca 结构一样处理。

n   把程序里的宿主变量定义成线程安全的。也就是说要小心处理程序里的全局变量和

静态变量。

n   避免同一时刻不同线程使用同一个运行时上下文。

static int insert_data( sql_context );

static int start();

int

main()

{

  pthread_t tid1, tid2;

   /* 创建两个线程 */

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

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

  exit(1);

  }

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

  exit(1);

  }

  if( pthread_join( tid2,NULL ) ){

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

  exit(1);

  }

  exit(0);

}

int

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

  EXEC SQL CONTEXT ALLOCATE :context;

EXEC SQL CONTEXT USE :context;

  EXEC SQL CONNECT :uid;

  if( SQLCODE < 0 ){

  printf( "创建数据库连接失败,%d:%s\n", SQLCODE,sqlca.sqlerrm.sqlerrmc);

  return -1;

  }insert_data( context );

  EXEC SQL COMMIT WORK RELEASE;

  if( SQLCODE < 0 ){

  printf( "断开数据库连接失败!%d:%s\n", SQLCODE,sqlca.sqlerrm.sqlerrmc );

insert_data( context )

  sql_context context;

{

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

  char  name[11];

  int age;

  int i;

  strcpy( name, "test" );

  age = 20;

  EXEC SQL CONTEXT USE :context;/* 指定执行 SQL 语句的上下文 */