基于Oracle plsql的多线程编程架构 (附存储过程)

原则：

1. 提供一个脱离业务、通用性强的功能组件。

2. 易于复用，代码修改少，可配置满足不同要求。

3. 对控制重复执行有所考虑。

4. 组件提供人性化的客户交互界面，解决进度情况展示的问题。

5. 能有一个实现和效率之间的平衡。

方法：

此组件中的并行执行遵循了几乎相同的逻辑。通常可以将某个大“任务”划分为较小的部分，并且并发地执行各个部分。例如，如果需要计算一大批结果并把数据保存到数据库中，那么完全可以建立4 个或更多并行会话（P001~P004）来一起执行存储过程，任务的分派有一个任务分派器来做，分派器可以按照每个进程的负载情况均匀的分派任务。每个会话分别调用预定义的业务过程来执行分派器分派的任务。当需要提交处理结果的时候，可以在每个业务过程内进行保存。

此组件作为一种实现架构，可以使一些要求吞吐量大、执行效率高的的操作得到大幅改善，使其能够呈数量级提高。由于此架构对系统资源要求较高，通常情况下应该在非高峰期而且有足够资源的情况下之用。

DBMS_SCHEDULER是Oracle 10G中新增的一个包，与老版本的DBMS_JOB包相比，DBMS_SCHEDULER有很多新特性。Oracle 10g引入DBMS_SCHEDULER来替代先前的DBMS_JOB,在功能方面,它比DBMS_JOB提供了更强大的功能和更灵活的机制。

DBMS_JOB这个程序包存在的问题是它只能够处理 PL/SQL 代码段，即仅能处理匿名程序块和存储程序单元。它不能在数据库外部处理操作系统命令文件或可执行文件中的任何东西。 

为此，您将不得不求助于操作系统调度实用工具。另外DBMS_JOB所生成任务进程一旦生成就在数据库中一直有效，不能在任务结束后自动终止。

DBMS_SCHEDULE是直接在数据库内部的一个作业调度实用程序，强大到足够处理所有类型的作业，而不只是 PL/SQL 代码段。它可以在处理任务执行结束后自动终止。最好的一点是它是数据库自带的，无需任何额外的成本，这样我们在实现上直接使用即可。

• 前台用户：主要是进行程序调度，主要是任务是把我程序执行时机。

• 任务列表：通过一个普通表实现，该表中主要包括了业务过程执行过程中所需要的入参，参数的形式为‘|’分隔的字符串。同时附加了异常及进度信息。该表是由程序开发人员根据具体的业务定义结构并生成入参数据。

• 进程控制：根据系统参数或业务参数调用DBMS_SCHEDULER生成对应个数的服务进程。依据当前进程执行情况，控制任务的重复执行。当出现紧急情况时终止所有服务进程。

• 任务读取：通过ORACLE的自制事务及锁特性，实现任务读取的一致性，即每次服务进程处理一行任务数据的时候，不被其它的服务进程重复读取。

• 业务过程：该部分同样由程序开发人员根据具体业务类型开发存储过程。该过程根据传入的过程名称和参数个数动态调用业务存储过程。

• 服务进程：ORACLE自动管理的进程，服务进程的数量取决于“进程控制”创建的进程数。服务进程主要工作1、通过“任务读取”获得“业务过程”的入参。2、调用“业务过程”生成业务数据。

• 数据存储：业务过程处理之后生成的结果。

• 进程监视：“前台用户”调用之后任务执行的监控，包括正在执行情况及最终执行结果。

此组件向开发人员公布3个系统接口，1个调试接口。

• PKG_多线程服务.PRC_进程控制

入参：

PRM_PROGRAM   即要调用的业务过程名称。

PRM_PARMCOUNT 即对应业务过程的参数个数

• PKG_多线程服务.PRC_进程停止

直接终止后台正在运行的多线程服务。

• PKG_多线程服务.PRC_调试使用

入参：

PRM_PROGRAM   即要调用的业务过程名称。

PRM_PARMS      即对应业务过程的参数字符串。

因为是动态调用存储过程，所以SC01中的参数个数必须同业务过程个数严格对应，提供此方法主要是让开发人员调试使用。

• 任务列表SC01

开发人员要压入的任务，即业务过程的参数。参数必须以‘|’分隔，并且保证在多线程服务运行的过程中，其他模块不能对SC01进行DML操作，为实现其他模块不能操作SC01，在任何DML操作之前必须执行一个语句如下：

SELECTCOUNT(*)

      INTO N_EXISTS

      FROM USER_SCHEDULER_JOBSS

     WHERE S.STATE = 'RUNNING'

AND S.JOB_ACTION = 'PKG_多线程服务.PRC_服务进程';

前台查询SC02、SC03视图