- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
不同应用在各自独立的进程中运行。当应用以任何形式启动时,系统为其创建进程,该进程将持续运行。当进程完成当前任务处于等待状态,且系统资源不足时,系统自动回收。
在启动应用时,系统会为该应用创建一个称为“主线程”的执行线程。该线程随着应用创建或消失,是应用的核心线程。UI界面的显示和更新等操作,都是在主线程上进行。主线程又称UI线程,默认情况下,所有的操作都是在主线程上执行。如果需要执行比较耗时的任务(如下载文件、查询数据库),可创建其他线程来处理。
如果应用的业务逻辑比较复杂,可能需要创建多个线程来执行多个任务。这种情况下,代码复杂难以维护,任务与线程的交互也会更加繁杂。要解决此问题,开发者可以使用“TaskDispatcher”来分发不同的任务。
TaskDispatcher是一个任务分发器,它是Ability分发任务的基本接口,隐藏任务所在线程的实现细节。
在UI线程上运行的任务默认以高优先级运行,如果某个任务无需等待结果,则可以用低优先级。
表1 线程优先级介绍
优先级 | 详细描述 |
---|---|
HIGH | 最高任务优先级,比默认优先级、低优先级的任务有更高的几率得到执行。 |
DEFAULT | 默认任务优先级, 比低优先级的任务有更高的几率得到执行。 |
LOW | 低任务优先级,比高优先级、默认优先级的任务有更低的几率得到执行。 |
系统提供的任务分发器有GlobalTaskDispatcher、ParallelTaskDispatcher、SerialTaskDispatcher 、SpecTaskDispatcher。
TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher(TaskPriority.DEFAULT);
globalTaskDispatcher.syncDispatch(() -> HiLog.info(LABEL_LOG,"Sync task1 run" + System.lineSeparator()));
HiLog.info(LABEL_LOG,"After sync task1" + System.lineSeparator());
globalTaskDispatcher.syncDispatch(() -> HiLog.info(LABEL_LOG,"Sync task2 run" + System.lineSeparator()));
HiLog.info(LABEL_LOG,"After sync task2" + System.lineSeparator());
执行结果:
TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher(TaskPriority.DEFAULT);
globalTaskDispatcher.asyncDispatch(() -> {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
HiLog.error(LABEL_LOG, "%{public}s", "AsyncDispatch InterruptedException");
}
HiLog.info(LABEL_LOG,"Async task1 run" + System.lineSeparator());
});
HiLog.info(LABEL_LOG,"After async task1" + System.lineSeparator());
globalTaskDispatcher.asyncDispatch(() -> {
try {
Thread.sleep(200);
} catch (InterruptedException e) {
HiLog.error(LABEL_LOG, "%{public}s", "AsyncDispatch InterruptedException");
}
HiLog.info(LABEL_LOG,"Async task2 run" + System.lineSeparator());
});
HiLog.info(LABEL_LOG,"After async task2" + System.lineSeparator());
执行结果:在两个异步执行中添加延时,更加体现效果
TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher(TaskPriority.DEFAULT);
final long callTime = System.currentTimeMillis();
globalTaskDispatcher.delayDispatch(() -> {
HiLog.info(LABEL_LOG,"DelayDispatch task1 run" + System.lineSeparator());
final long actualDelayMs = System.currentTimeMillis() - callTime;
HiLog.info(LABEL_LOG,"ActualDelayTime >= delayTime : " + (actualDelayMs >= DELAY_TIME));
}, DELAY_TIME);
HiLog.info(LABEL_LOG,"After delayDispatch task1" + System.lineSeparator());
执行结果:
TaskDispatcher dispatcher = createParallelTaskDispatcher("", TaskPriority.DEFAULT);
Group group = dispatcher.createDispatchGroup();
dispatcher.asyncGroupDispatch(group, () -> {
HiLog.info(LABEL_LOG,"GroupTask1 is running" + System.lineSeparator());
});
dispatcher.asyncGroupDispatch(group, () -> {
HiLog.info(LABEL_LOG,"GroupTask2 is running" + System.lineSeparator());
});
dispatcher.groupDispatchNotify(group, () -> HiLog.info(LABEL_LOG,
"此任务在组中的所有任务完成后运行" + System.lineSeparator()));
运行结果:结果性不确定、没有执行顺序可言
TaskDispatcher dispatcher = getUITaskDispatcher();
Revocable revocable = dispatcher.delayDispatch(() -> {
HiLog.info(LABEL_LOG,"Delay dispatch" + System.lineSeparator());
}, 50);
boolean revoked = revocable.revoke();
HiLog.info(LABEL_LOG,"Revoke result :" + revoked);
运行结果:
TaskDispatcher dispatcher = createParallelTaskDispatcher("SyncBarrierDispatcher", TaskPriority.DEFAULT);
Group group = dispatcher.createDispatchGroup();
dispatcher.asyncGroupDispatch(group, () -> {
HiLog.info(LABEL_LOG,"Task1 is running" + System.lineSeparator());
});
dispatcher.asyncGroupDispatch(group, () -> {
HiLog.info(LABEL_LOG,"Task2 is running" + System.lineSeparator());
});
dispatcher.syncDispatchBarrier(() -> {
HiLog.info(LABEL_LOG,"Barrier" + System.lineSeparator());
});
HiLog.info(LABEL_LOG,"After syncDispatchBarrier" + System.lineSeparator());
执行结果:
执行20次后结果:
TaskDispatcher dispatcher = createParallelTaskDispatcher("AsyncBarrierDispatcher", TaskPriority.DEFAULT);
Group group = dispatcher.createDispatchGroup();
dispatcher.asyncGroupDispatch(group, () -> {
HiLog.info(LABEL_LOG,"Task1 is running" + System.lineSeparator());
});
dispatcher.asyncGroupDispatch(group, () -> {
HiLog.info(LABEL_LOG,"Task2 is running" + System.lineSeparator());
});
dispatcher.asyncDispatchBarrier(() -> {
HiLog.info(LABEL_LOG,"Barrier" + System.lineSeparator());
});
HiLog.info(LABEL_LOG,"After asyncDispatchBarrier" + System.lineSeparator());
执行结果:1和2的执行顺序不定,但总在3之前执行;4不需要等待1、2、3执行完成。
final CountDownLatch latch = new CountDownLatch(10);
final ArrayList<Long> indexList = new ArrayList<>(10);
TaskDispatcher globalTaskDispatcher = getGlobalTaskDispatcher(TaskPriority.DEFAULT);
//执行10次
globalTaskDispatcher.applyDispatch(index -> {
indexList.add(index);
latch.countDown();
}, 10);
//超时出错
try {
latch.await();
} catch (InterruptedException exception) {
HiLog.error(LABEL_LOG, "%{public}s", "applyDispatchTask InterruptedException");
}
HiLog.info(LABEL_LOG,"List size matches :" + (indexList.size() == TASK_TOTAL));
执行结果:
关闭。这个问题是opinion-based .它目前不接受答案。 想要改进这个问题? 更新问题,以便 editing this post 可以用事实和引用来回答它. 关闭 9 年前。 Improve
介绍篇 什么是MiniApis? MiniApis的特点和优势 MiniApis的应用场景 环境搭建 系统要求 安装MiniApis 配置开发环境 基础概念 MiniApis架构概述
我正在从“JavaScript 圣经”一书中学习 javascript,但我遇到了一些困难。我试图理解这段代码: function checkIt(evt) { evt = (evt) ? e
package com.fastone.www.javademo.stringintern; /** * * String.intern()是一个Native方法, * 它的作用是:如果字
您会推荐哪些资源来学习 AppleScript。我使用具有 Objective-C 背景的传统 C/C++。 我也在寻找有关如何更好地开发和从脚本编辑器获取更快文档的技巧。示例提示是“查找要编写脚本的
关闭。这个问题不满足Stack Overflow guidelines .它目前不接受答案。 想改善这个问题吗?更新问题,使其成为 on-topic对于堆栈溢出。 4年前关闭。 Improve thi
关闭。这个问题不满足Stack Overflow guidelines .它目前不接受答案。 想改善这个问题吗?更新问题,使其成为 on-topic对于堆栈溢出。 7年前关闭。 Improve thi
关闭。这个问题不符合 Stack Overflow guidelines 。它目前不接受答案。 想改善这个问题吗?更新问题,以便堆栈溢出为 on-topic。 6年前关闭。 Improve this
我是塞内加尔的阿里。我今年60岁(也许这是我真正的问题-笑脸!!!)。 我正在学习Flutter和Dart。今天,我想使用给定数据模型的列表(它的名称是Mortalite,请参见下面的代码)。 我尝试
关闭。这个问题是off-topic .它目前不接受答案。 想改进这个问题? Update the question所以它是on-topic对于堆栈溢出。 9年前关闭。 Improve this que
学习 Cappuccino 的最佳来源是什么?我从事“传统”网络开发,但我对这个新框架非常感兴趣。请注意,我对 Objective-C 毫无了解。 最佳答案 如上所述,该网站是一个好地方,但还有一些其
我正在学习如何使用 hashMap,有人可以检查我编写的这段代码并告诉我它是否正确吗?这个想法是有一个在公司工作的员工列表,我想从 hashMap 添加和删除员工。 public class Staf
我正在尝试将 jQuery 与 CoffeScript 一起使用。我按照博客中的说明操作,指示使用 $ -> 或 jQuery -> 而不是 .ready() 。我玩了一下代码,但我似乎无法理解我出错
还在学习,还有很多问题,所以这里有一些。我正在进行 javascript -> PHP 转换,并希望确保这些做法是正确的。是$dailyparams->$calories = $calories;一条
我目前正在学习 SQL,以便从我们的 Magento 数据库制作一个简单的 RFM 报告,我目前可以通过导出两个查询并将它们粘贴到 Excel 模板中来完成此操作,我想摆脱 Excel 模板。 我认为
我知道我很可能会因为这个问题而受到抨击,但没有人问,我求助于你。这是否是一个正确的 javascript > php 转换 - 在我开始不良做法之前,我想知道这是否是解决此问题的正确方法。 JavaS
除了 Ruby-Doc 之外,哪些来源最适合获取一些示例和教程,尤其是关于 Ruby 中的 Tk/Tile?我发现自己更正常了 http://www.tutorialspoint.com/ruby/r
我只在第一次收到警告。这正常吗? >>> cv=LassoCV(cv=10).fit(x,y) C:\Python27\lib\site-packages\scikit_learn-0.14.1-py
按照目前的情况,这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持,但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visit the
As it currently stands, this question is not a good fit for our Q&A format. We expect answers to be
我是一名优秀的程序员,十分优秀!