Oracle jobs为Oracle开发人员和数据库管理员提供了数据库层面维护的极大便利性。对于Oracle jobs在Oracle 9i之前,是由dbms_jobs来实现,而到了10g之后,多出了dbms_scheduler方式。两者同样可以添加Oracle job,只不过dbms_scheduler的功能更为强大。在使用Oracle jobs时,我们不得不关注job_queue_processes参数,用于设定job队列可以启动的进程数。本文即是围绕此展开。查看该参数命令:
show parameter job;
1、job_queue_processes参数
alter system set job_queue_processes= 0,,,1000
下面是11g reference的描述:
JOB_QUEUE_PROCESSES specifies the maximum number of job slaves per instance that can be created for the execution of DBMS_JOB jobs and Oracle Scheduler (DBMS_SCHEDULER) jobs. DBMS_JOB and Oracle Scheduler share the same job coordinator and job slaves, and they are both controlled by the JOB_QUEUE_PROCESSES parameter.
If the value of JOB_QUEUE_PROCESSES is set to 0, then DBMS_JOB jobs and Oracle Scheduler jobs will not run on the instance.If JOB_QUEUE_PROCESSES is set to a value in the range of 1 to 1000, then DBMS_JOB jobs and Oracle Scheduler jobs will run. The actual number of job slaves created for Oracle Scheduler jobs is auto-tuned by the Scheduler depending on several factors, including available resources, Resource Manager settings, and currently running jobs. However, the combined total number of job slaves running DBMS_JOB jobs and Oracle Scheduler jobs on an instance can never exceed the value of JOB_QUEUE_PROCESSES for that instance. The number of job slaves running Oracle Scheduler jobs is additionally limited to the value of the MAX_JOB_SLAVE_PROCESSES Scheduler attribute.
Advanced replication uses Oracle Scheduler for data refreshes. Oracle Streams Advanced Queuing uses Oracle Scheduler for message propagation. Materialized views use Oracle Scheduler for automatic refreshes. Setting JOB_QUEUE_PROCESS to 0 will disable these features as well as any other features that use Oracle Scheduler or DBMS_JOB.
a、从上面的描述可知,对于Oracle job进程,包含协调进程(主进程)以及奴隶进程(子进程)。
b、job_queue_processes取值范围为0到1000,总共可创建多少个job进程由job_queue_processes参数来决定。
c、当job_queue_processes大于1时,且并行执行job时,至少一个为协调进程。其总数不会超出job_queue_processes的值。
d、job_queue_processes参数的值为且DBMS_JOB与DBMS_SCHEDULER共享。
e、job_queue_processes参数,当设定该值为0的时候则任意方式创建的job都不会运行。
f、非零值的job_queue_processes,其job子进程数依赖于可用资源,资源配置方式以及当前运行的job数来自行调整。
g、此外对于Scheduler jobs方式还受限制于scheduler属性MAX_JOB_SLAVE_PROCESSES的设置。
h、可以通过DBMS_SCHEDULER.SET_SCHEDULER_ATTRIBUTE来设置max_job_slave_processes
2、测试参数job_queue_processes为1的情形
[sql] view plaincopyprint?
-->演示环境
SQL> select * from v$version where rownum<2;
BANNER
--------------------------------------------------------------------------------
Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production
-->创建测试用表
CREATE TABLE tb_job
(
job_name VARCHAR2 (5),
update_dt VARCHAR2 (20)
);
-->添加多个Oracle job来并发执行
SQL> ho more add_job.sql
DECLARE
job_name VARCHAR2 (20);
BEGIN
DBMS_OUTPUT.put_line ('Current sysdate is ' || TO_CHAR (SYSDATE, 'yyyymmdd hh24:mi:ss'));
FOR i IN 1 .. 5
LOOP
job_name := 'JOB_' || TO_CHAR (i);
sys.DBMS_SCHEDULER.create_job (
job_name => job_name,
start_date => sysdate+1/1440,
repeat_interval => 'freq = minutely; interval=1',
end_date => NULL,
job_class => 'DEFAULT_JOB_CLASS',
job_type => 'PLSQL_BLOCK',
job_action => '
begin
INSERT INTO tb_job
SELECT '''
|| job_name
|| ''', TO_CHAR (SYSDATE, ''yyyymmdd hh24:mi:ss'') FROM DUAL;
dbms_lock.sleep(60);
commit;
end;
',
enabled => true,
comments => 'my test job');
END LOOP;
END;
/
SQL> @add_job
PL/SQL procedure successfully completed.
-->查看job_queue_processes参数的值
SQL> show parameter job
NAME TYPE VALUE
------------------------------------ ----------- ------------------------------
job_queue_processes integer 1
-->此时和Job相关的进程一个,为ora_j000
SQL> ho ps -ef | grep rac11g | grep ora_j | grep -v grep
oracle 9692 1 4 12:03 ? 00:00:01 ora_j000_rac11g1
-->查看刚刚添加的job
-->下面的NEXT_RUN_DATE在秒级别上稍有差异,其实在定义job时,这个是由于前面的for循环造成的延迟
-->在此忽略这个细微的差异
SQL> @jobs
OWNER JOB_NAME ENABL JOB_CLASS NEXT_RUN_DATE
------------ -------------- ----- ------------------------------ -----------------------------------
SCOTT JOB_1 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.21.33.000000 PM +08:00
SCOTT JOB_2 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.21.33.000000 PM +08:00
SCOTT JOB_3 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.21.33.000000 PM +08:00
SCOTT JOB_4 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.21.34.000000 PM +08:00
SCOTT JOB_5 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.21.34.000000 PM +08:00
-->job执行的情况,可以看到5个job被逐一执行
-->尽管我们定义时的NEXT_RUN_DATE相差1秒,而此时job的执行后则每一个相差1分钟
-->job_1与job_5相差4分多钟,这是由于我们定义了dbms_lock.sleep(60)为1分钟
-->其次可以看出由于只有一个job进程,因此每一个job是一个一个被执行
SQL> select * from tb_job;
JOB_N UPDATE_DT
----- --------------------
JOB_1 20130319 12:21:33
JOB_2 20130319 12:22:35
JOB_3 20130319 12:23:37
JOB_4 20130319 12:24:39
JOB_5 20130319 12:25:41
3、测试参数job_queue_processes大于1的情形
[sql] view plaincopyprint?
-->首先移除之前的job
SQL> ho more remove_job.sql
DECLARE
job_name VARCHAR2 (10);
BEGIN
FOR i IN 1 .. 5
LOOP
job_name := 'JOB_' || TO_CHAR (i);
sys.DBMS_SCHEDULER.drop_job (job_name, force => TRUE);
END LOOP;
END;
/
SQL> @remove_job
PL/SQL procedure successfully completed.
-->此时设置job_queue_processes的值为6
SQL> alter system set job_queue_processes=6;
System altered.
-->清空测试用表
SQL> truncate table tb_job;
Table truncated.
-->此时Oracle为job启动了2个进程
SQL> ho ps -ef | grep rac11g | grep ora_j | grep -v grep
oracle 3477 1 9 12:29 ? 00:00:01 ora_j000_rac11g1
oracle 3491 1 4 12:29 ? 00:00:00 ora_j001_rac11g1
-->添加多个job
SQL> @add_job
PL/SQL procedure successfully completed.
--> Author : Robinson
--> Blog : http://blog.csdn.net/robinson_0612
SQL> @jobs
OWNER JOB_NAME ENABL JOB_CLASS NEXT_RUN_DATE
-------------------- ----------- ----- --------------------- -----------------------------------
SCOTT JOB_1 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.31.55.000000 PM +08:00
SCOTT JOB_2 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.31.56.000000 PM +08:00
SCOTT JOB_3 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.31.56.000000 PM +08:00
SCOTT JOB_4 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.31.56.000000 PM +08:00
SCOTT JOB_5 TRUE DEFAULT_JOB_CLASS 19-MAR-13 12.31.56.000000 PM +08:00
-->片刻后可以看到job进程总数达到6个
SQL> ho ps -ef | grep rac11g | grep ora_j | grep -v grep
oracle 7668 1 1 11:57 ? 00:00:01 ora_j000_rac11g1
oracle 7678 1 0 11:57 ? 00:00:01 ora_j001_rac11g1
oracle 7700 1 1 11:57 ? 00:00:01 ora_j002_rac11g1
oracle 9230 1 0 11:57 ? 00:00:00 ora_j003_rac11g1
oracle 9257 1 2 11:58 ? 00:00:01 ora_j005_rac11g1
oracle 9353 1 7 11:59 ? 00:00:00 ora_j004_rac11g1
-->查看表tb_job的情形
SQL> select * from tb_job order by 1,2;
JOB_N UPDATE_DT
----- --------------------
JOB_1 20130319 12:31:57
JOB_1 20130319 12:32:58
JOB_1 20130319 12:33:59
JOB_2 20130319 12:31:58
JOB_2 20130319 12:32:59
JOB_2 20130319 12:34:00
JOB_3 20130319 12:31:58
JOB_3 20130319 12:32:59
JOB_3 20130319 12:34:00
JOB_4 20130319 12:31:59
JOB_4 20130319 12:33:00
JOB_4 20130319 12:34:01
JOB_5 20130319 12:31:58
JOB_5 20130319 12:32:59
JOB_5 20130319 12:34:00
-->从上面的查询结果可知每一个job的上一次与下一次执行间隔基本保持在1分钟
-->不同job之间的每一次执行时间基本上是相同的,这与job_queue_processes为1时完全不一样
-->也就是说即使是job_5,基本上与job_1是同时执行,而不是像前面测试那样前面所有的执行完后才被执行
-->移除job
SQL> @remove_job
PL/SQL procedure successfully completed.
-->移除测试表
SQL> drop table tb_job purge;
Table dropped.
4、小结
a、job_queue_processes参数决定了job作业能够使用的总进程数。
b、当该参数为0值,任何job都不会被执行,建议合理设置该值且至少大于1。
c、对于job运行时间也应该尽量合理的设置间隔以及启动时间。
d、如果同一时间内运行的Job数很多,过小的参数值导致job不得不进行等待。而过大的参数值则消耗更多的系统资源。
f、对于存在依赖关系的job,尽可能将其进行合并到一个job中,如使用chain等。
参考至:http://blog.sina.com.cn/s/blog_62defbef0101opv0.html
如有错误,欢迎指正
邮箱:czmcj@163.com
相关推荐
### 使用`dev_queue_xmit`与`dev_hard_start_xmit`方法实现数据包发送 在Linux内核开发中,网络栈的功能实现极为关键。本文旨在深入解析如何利用`dev_queue_xmit`和`dev_hard_start_xmit`这两个核心函数来实现...
STL 中的 priority_queue priority_queue 是 STL 中的一种容器,可以实现优先级队列的功能。下面,我们将详细介绍 priority_queue 的使用方法和实现原理。 priority_queue 的基本概念 priority_queue 是一种特殊...
官方离线安装包,亲测可用
官方离线安装包,亲测可用。使用rpm -ivh [rpm完整包名] 进行安装
ngx_queue_t是Nginx框架中的一个核心数据结构,用于实现高效的队列操作。这个数据结构在Nginx中广泛应用于请求处理、事件调度、模块通信等场景,它提供了线程安全的队列操作,是Nginx高性能的关键之一。在本资源中,...
`DISPATCH_QUEUE_CONCURRENT`是标记并行队列的常量,表明队列上的任务可以并发执行,即多个任务可以在同一时间运行,充分利用多核处理器的优势。 `DISPATCH_QUEUE_CONCURRENT`队列允许任务同时运行,但需要注意的是...
无锁队列(Lock-Free Queue)是一种在多线程编程中用于提高并发性能的数据结构。在传统的线程安全队列中,通常会使用锁来保护数据的同步,但这种做法可能会导致线程间的竞争条件,进而产生性能瓶颈。无锁队列通过...
在C++编程语言中,`std::queue`是标准库中的一个模板类,它提供了一种先进先出(FIFO,First In First Out)的数据结构,通常用于模拟队列。然而,有时候根据特定需求,开发者可能希望自定义队列的元素类型或者实现...
- `g_async_queue_push`:此函数首先锁定互斥量,然后调用`g_async_queue_push_unlocked`,最后解锁互斥量。 ##### 从异步队列中弹出数据 ```c gpointer g_async_queue_pop_intern_unlocked(GAsyncQueue *queue, ...
在“Linux_message_linux_blocking_queue_linux”这个主题中,我们将深入探讨Linux消息队列的原理、使用方法以及其在实际编程中的应用。 首先,理解Linux消息队列的基本概念。消息队列是由内核管理的数据结构,它...
《PyPI上的sqs_queue-0.1.1.tar.gz:Python库解析与分布式系统实践》 在Python的生态系统中,PyPI(Python Package Index)是最重要的资源仓库,它为开发者提供了无数的开源库和工具,以简化开发过程。本文将深入...
在C++中实现队列,我们可以利用STL(Standard Template Library)中的`queue`容器,也可以自定义队列结构来实现。 ### 1. C++ STL中的`queue` C++标准库提供了`<queue>`头文件,其中包含`queue`模板类。它通常基于`...
python库。 资源全名:persist_queue-0.4.2-py2.py3-none-any.whl
第二部分则详细讲解了具体的管理实践和技术细节。 - **文本约定**:使用特定的格式来区分代码、命令等。 - **目录变量约定**:为方便理解,文档中的路径和文件名可能会使用变量表示。 #### 四、管理任务与工具 在...
- `job_queue_processes` 参数控制并发执行的 Job 数量,可以通过 `ALTER SYSTEM SET job_queue_processes=<value>` 来设置,但最大值不能超过 1000。 - `job_queue_interval` 参数定义了调度作业刷新的频率,单位...
标签"aodv_opnet ex opnet_process queue_opnet"进一步指出了AODV在OPNET中的实现、OPNET的进程机制以及队列操作。 从压缩包的文件名来看,我们可以推测出以下几个关键模块: 1. `aodv_rte.pr.c`:这可能是AODV...
自己编写优类似优先队列数据(priority_queue)的功能,适合上交的课程设计作业
初始化相关参数job_queue_processes alter system set job_queue_processes=39 scope=spfile;//最大值不能超过1000 ;job_queue_interval = 10 //调度作业刷新频率秒为单位 job_queue_process 表示oracle能够并发的...
在实际应用中,UVC驱动程序不仅需要处理视频数据的传输,还要处理设备状态的改变、设置摄像头参数(如分辨率、帧率)以及错误处理。开发者可能需要深入理解USB协议、视频编码解码原理以及多线程编程,以构建一个稳定...
标题中的"PyPI 官网下载 | flask_queue_broker_client-0.0.2-py3-none-any.whl"指的是Python Package Index (PyPI)上发布的`flask_queue_broker_client`库的一个版本,具体为0.0.2。PyPI是Python开发者发布和分享...