使用Oracle 11.2
嗨，
这就是我想要做的：我正在使用 dbms_scheduler 安排作业。要调度的作业数量不固定，最多应同时运行 4 个作业。调度作业的过程应等到所有作业完成。如果一项作业失败，“调度”过程也应该失败，并且所有剩余的调度作业都应该从调度程序中删除。
目前我不得不睡觉并循环轮询表 user_scheduler_jobs 。
我是 PL/SQL 新手，缺乏经验，所以请不要对我太严厉;)
这是迄今为止我的代码。
首先是调度作业的片段：
BEGIN
FOR r IN (SELECT p_values FROM some_table WHERE flag = 0 )
LOOP
-- count running jobs
SELECT count(*) INTO v_cnt
FROM user_scheduler_jobs
WHERE job_name LIKE 'something%';
/*
If max number of parallel jobs is reached, then wait before starting a new one.
*/
WHILE v_cnt >= l_max_parallel_jobs
LOOP
dbms_lock.sleep(10);
SELECT count(*) INTO v_cnt
FROM user_scheduler_jobs
WHERE job_name LIKE 'something%' AND state = 'RUNNING';
SELECT count(*) INTO v_cnt_failures
FROM user_scheduler_jobs
WHERE job_name LIKE 'something%' AND state = 'FAILED' OR state = 'BROKEN';
IF v_cnt_failures > 0 THEN RAISE some_exception; END IF;
END LOOP;
-- Start a new Job
v_job_name := 'something_someting_' || p_values;
v_job_action := 'begin user.some_procedure(''' || r.p_values || '''); end;';
dbms_scheduler.create_job(job_name => v_job_name,
job_type => 'PLSQL_BLOCK',
job_action => v_job_action,
comments => 'Some comment ' || v_job_name,
enabled => FALSE,
auto_drop => FALSE);
dbms_scheduler.set_attribute(NAME => v_job_name,
ATTRIBUTE => 'max_failures',
VALUE => '1');
dbms_scheduler.set_attribute(NAME => v_job_name,
ATTRIBUTE => 'max_runs',
VALUE => '1');
dbms_scheduler.enable(v_job_name);
v_job_count := v_job_count + 1;
-- array for all jobs
v_jobs_aat(v_job_count) := v_job_name;
END LOOP;
-- ... Wait till all jobs have finisched.
check_queue_completion(v_jobs_aat); -- see procedure below
END;
等待最后四项工作完成的程序：
PROCEDURE check_queue_completion(p_jobs_aat IN OUT t_jobs_aat) AS
v_state user_scheduler_jobs.state%TYPE;
v_index PLS_INTEGER;
v_done BOOLEAN := TRUE;
-- Exceptions
e_job_failure EXCEPTION;
BEGIN
WHILE v_done
LOOP
v_done := FALSE;
FOR i IN p_jobs_aat.first..p_jobs_aat.last
LOOP
SELECT state INTO v_state FROM user_scheduler_jobs WHERE job_name = p_jobs_aat(i);
--dbms_output.put_line('Status: ' || v_state);
CASE
WHEN v_state = 'SUCCEEDED' OR v_state = 'COMPLETED' THEN
dbms_output.put_line(p_jobs_aat(i) || ' SUCCEEDED');
dbms_scheduler.drop_job(job_name => p_jobs_aat(i), force => TRUE);
p_jobs_aat.delete(i);
WHEN v_state = 'FAILED' OR v_state = 'BROKEN' THEN
--Exception auslösen
dbms_output.put_line(p_jobs_aat(i) || ' FAILED');
RAISE e_job_failure;
WHEN v_state = 'RUNNING' OR v_state = 'RETRY SCHEDULED' THEN
NULL;
dbms_output.put_line(p_jobs_aat(i) || ' RUNNING or RETRY SCHEDULED');
v_done := TRUE;
/*DISABLED, SCHEDULED, REMOTE, CHAIN_STALLED*/
ELSE
dbms_output.put_line(p_jobs_aat(i) || ' ELSE');
dbms_scheduler.drop_job(job_name => p_jobs_aat(i), force => TRUE);
p_jobs_aat.delete(i);
END CASE;
END LOOP;
hifa.gen_sleep(30);
END LOOP;
IF p_jobs_aat.count > 0 THEN delete_jobs_in_queue(p_jobs_aat); END IF;
EXCEPTION WHEN e_job_failure THEN
delete_jobs_in_queue(p_jobs_aat);
RAISE_APPLICATION_ERROR(-20500, 'some error message');
END check_queue_completion;
它确实有效，但看起来像是一些可怕的黑客。
有没有更好的方法：
DECLARE
cnt NUMBER:=1;
BEGIN
WHILE cnt>=1
LOOP
SELECT count(1) INTO cnt FROM dba_scheduler_running_jobs srj
WHERE srj.job_name IN ('TEST_JOB1','TEST_JOB2');
IF cnt>0 THEN
dbms_lock.sleep (5);
END IF;
END LOOP;
dbms_output.put_line('ASASA');
END;
一直在使用自制的“调度程序”，它从队列（id 表）中选取元素，并将每个元素分配给 DBMS_SCHEDULER 作业，以由调度程序自行处理。为了跟踪有多少作业被调度，我一直在使用 DBMS_ALERT 机制（在作业提交给调度程序之前注册一个警报，并在作业完成之前引发警报）。通过这种方式，我可以跟踪“并行”运行的作业数量，并且还可以通过在设置参数表中保留一个值来在运行时限制该数量。此设置在从 v12 一直到 v19 的 2 节点 RAC 系统中表现无可挑剔。 根据计划和执行的作业类型（以及在底层服务器上），我已成功实现每小时 6.5K - 12K 作业的吞吐量，同时将总体 CPU 利用率保持在 55% 以下。
使用 dbms_alert 或 dbms_pipe 发送/接收有关作业开始/完成的信息。仅当您未在预期时间内收到信息时才查询作业表。
请注意，DBMS_PIPE 不适用于 RAC（即接收方 <> 发送方）。使用DBMS_ALERT，在RAC下完美运行。
Oracle Scheduler 大量使用 Oracle Rersource Manager，只需提交您的作业，定义一个结束通知，然后让一个任务等待您的事件 Q，该事件 Q 会计算已提交的作业和已完成的作业。
您使用 Oracle 资源管理器来控制并发运行的最大作业数。这也将基于数据库总负载，保护其他用户免受作业淹没的系统的影响。