当前位置:网站首页>使用工作队列管理器(三)
使用工作队列管理器(三)
2022-08-03 12:19:00 【用户7741497】
管理类别
一个类别是一个独立的worker jobs池。当初始化一组worker jobs时,可以指定提供worker的类别。如果集合中的任何worker jobs在执行work项时请求额外的worker jobs,则新的worker jobs来自同一类别。
例如,假设系统提供的 SQL 类别分配了最多 8
个worker。然后,假设与BusinessIntelligence
相关的流程创建了一个类别,并将最多四个worker分配给该类别。如果 SQL 池中的所有worker在给定时间都参与了工作,则 BusinessIntelligence
类别中的worker可能仍然可以立即处理工作项。
系统包括两个不能删除的类别:SQL
和 Default
。 SQL 类别适用于系统执行的任何 SQL 处理,包括查询的并行处理。当在未指定类别的情况下初始化一组worker jobs时,默认类别提worker jobs。
每个类别都具有影响该类别中每个工作队列的行为的属性。这些属性是:
DefaultWorkers
当创建此类别中的工作队列且未指定worker job 计数时,这将成为工作队列中worker job 的数量。此属性的默认值是核心数。
MaxActiveWorkers
在此类别的job服务请求池中保留的活动worker job的最大数量。检测到空闲job并自动启动新job以将最大活动job数保持在此限制附近。默认值为核心数的两倍。
MaxWorkers
此类别中工作队列的最大worker job数。如果在创建工作队列时指定了更多的worker job,则使用此限制。默认值为核心数的两倍。
要创建类别、调整类别属性和删除自定义类别,请导航到System Administration > Configuration > System Configuration > WQM Categories
.。自定义类别的名称区分大小写,可能包含字母、数字、下划线、破折号和句点。
使用回调
回调是工作队列管理器在完成工作项后必须执行的代码。可以使用回调有两个原因:
- 执行依赖于工作项完成的工作
- 如果选择异步完成工作项,则表示所有排队的工作都已完成
包括工作项的回调
要添加回调,请在将工作项添加到工作队列时调用 QueueCallback()
方法而不是 Queue()
方法:
method QueueCallback(work As %String, callback As %String, args... As %String) as %Status
work 和 args 方法与 Queue()
方法相同。但是,回调参数使用以下语法指定要执行的回调代码:
##class(Classname).ClassMethod
用于类方法$$entry^rtn
用于子程序
类方法或子例程必须以相同的顺序接受与主工作项相同的参数。主进程将相同的参数传递给主工作项和回调代码。
回调代码可以访问以下公共变量:
%job
,其中包含实际完成工作的进程的作业ID
%status
,其中包含工作单元返回的%Status
值%workqueue
,即工作队列实例的OREF
这些公共变量在回调中可用,但在工作项中不可用。
包括回调以确定完成
可以轮询工作队列管理器以确定完成,而不是使用 WaitForComplete()
方法等待工作队列中的所有排队工作完成后再返回主进程,如下所示:
- 如上一节所述,使用
QueueCallback()
方法而不是Queue()
方法将工作项添加到工作队列。 - 当所有工作项的工作完成后,在回调代码中将公共变量
%exit
设置为1
。 - 使用
Wait()
方法而不是WaitForComplete()
方法:
method Wait(qspec As %String, byRef AtEnd As %Boolean) as %Status
Wait()
方法等待来自回调的信号返回给调用者。具体来说,它等待回调代码将公共变量 %exit
设置为等于 1
。Wait()
通过引用返回 AtEnd
。 AtEnd
为 1
时,所有工作都已完成。或者,如果 AtEnd
为 0
,则一个或多个工作项未完成。
控制当前设备的输出
默认情况下,如果工作项向当前设备生成输出(WRITE
语句),工作队列会将输出保存在缓冲区中,直到 WaitForComplete()
或 Wait()
结束。如果希望工作项更早地生成输出,请让该工作项调用 %SYSTEM.Context.WorkMgr
类的 Flush()
类方法,例如:
set sc = $system.Context.WorkMgr().Flush()
当工作项调用此方法时,会导致父工作队列写入工作项的所有已保存输出。
此外,可以使用 -d
标志来禁止对当前设备的所有输出。在这种情况下,Flush()
方法什么也不做,因为没有输出。
暂停和恢复工作队列
%SYSTEM.WorkMgr
类提供了可用于在工作队列中暂停和恢复工作的方法:
Pause()
method Pause(timeout As %Integer, ByRef completed As %Boolean = 0) as %Status
阻止与此工作队列关联的worker jobs接受来自此工作队列的其他项目。 Pause()
方法还会停止任何正在进行的工作项。
timeout
参数表示方法在停止正在进行的工作项之前等待的时间量(以秒为单位)。超时时间过后,该方法返回完成值,该值指示调用 Pause()
方法时正在进行的工作项是否已完成。因此,可以传入超时值 0
以立即知道worker jobs是否完成了工作队列中的所有工作项。
Resume()
method Resume() as %Status
如果之前已使用 Pause()
方法暂停,则恢复此工作队列中的工作。具体来说,此方法使工作队列进程能够接受并启动工作队列中的任何其他项目。
边栏推荐
- -树的高度-
- R语言绘制时间序列的自相关函数图:使用acf函数可视化时间序列数据的自相关系数图
- net start mysql 启动报错:发生系统错误5。拒绝访问。
- Image fusion SDDGAN article learning
- R语言ggplot2可视化:使用ggpubr包的ggsummarystats函数可视化箱图(通过ggfunc参数设置)、在可视化图像的下方添加描述性统计结果表格
- 第十五章 源代码文件 REST API 简介
- 基于Sikuli GUI图像识别框架的PC客户端自动化测试实践
- 4500字归纳总结,一名软件测试工程师需要掌握的技能大全
- 基于php校园医院门诊管理系统获取(php毕业设计)
- awk入门教程
猜你喜欢
别再用if-else了,分享一下我使用“策略模式”的项目经验...
5个超好用手机开源自动化工具,哪个适合你?
After completing the interview and clearance collection of Alibaba, I successfully won the 15th Offer this year
shell编程条件语句
How to do App Automation Testing?Practical sharing of the whole process of App automation testing
从器件物理级提升到电路级
学习软件测试需要掌握哪些知识点呢?
ROS中编译通过但是遇到可执行文件找不到的问题
Filebeat 如何保持文件状态?
利用ChangeStream实现Amazon DocumentDB表级别容灾复制
随机推荐
我在母胎SOLO20年
JUC(三):锁核心类AQS ing
基于php旅游网站管理系统获取(php毕业设计)
深入理解MySQL事务MVCC的核心概念以及底层原理
免费的网络传真平台_发传真不显示发送号码
Take you understand the principle of CDN technology
一文带你弄懂 CDN 技术的原理
bash if conditional judgment
bash for循环
PolarFormer: Multi-camera 3D Object Detection with Polar Transformers 论文笔记
Simple implementation of a high-performance clone of Redis using .NET (1)
-找树根2-
【Verilog】HDLBits题解——Verification: Writing Testbenches
超多精美礼品等你来拿!2022年中国混沌工程调查启动
shell编程之条件语句
R language ggplot2 visualization: use the patchwork bag plot_layout function will be more visual image together, ncol parameter specifies the number of rows, specify byrow parameters configuration dia
特征工程学习笔记
899. 有序队列
一次内存泄露排查小结
How can I get a city's year-round weather data for free?Precipitation, temperature, humidity, solar radiation, etc.