- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
我正在制作一个 android 库。在我的库中我希望允许用户在后台或主线程中执行特定任务。
我想做这样的事情。
第一个场景
MyLibabry.with(context)
.performSomeTask(<params>)
.execute();
当用户编写上述代码段时。该任务应在后台执行。所以我将使用任何监听器返回任务的结果。
现在考虑下面的代码 fragment 。
第二个场景
Result result = MyLibabry.with(context)
.performSomeTask(<params>)
.get();
现在,当用户在语句末尾附加 get() 时。该任务应该在主线程上执行并阻塞其他线程。这就是 result 立即初始化的原因。
所以我的问题是,如果用户附加了 .get(),我如何实现该功能,performSomeTask()
中的线程应该在主线程上运行。否则在后台。
注意:不要专注于返回结果。我将在 Java 泛型中实现它。 我想知道的是如何使代码可重用,以便当用户仅附加 .get()
时,它将在主线程上运行。否则,相同的代码应该在后台运行。我不想写重复的代码。
您可以引用现有的库。
所以两个库具有相同的功能,还有更多的库具有相同的功能,我也想做同样的。
如果有人为此提供一个小例子,那就太好了。
最佳答案
(我希望您在上面的示例中通过返回值来澄清)所以这是针对您的任务的几种类型的单一解决方案。仔细查看在新线程中运行的任务。您需要在后台 ThreadPool 中启动您的操作....
注意!(另外我希望你澄清使用后台线程。例如,使用上面的代码和函数 .execute() - 不会启动新线程,而只是将新任务用于从静态线程池中的 BlockingQueue 执行)
那么接下来呢?使用函数 .get() 在 MainThread 中执行任务,您需要将此任务发布到当前操作循环中。你将帮助 Handler 和 Looper。回答你的问题,你应该知道,你只有一种方法来完成这项任务。 使用方法 .execute() 在后台线程中启动操作并使用方法 .get() 向 Handler 启动新任务。就是这样!
如果你想了解一些实现的例子,有很多种解决方案。我只是使用 Handler 和 HandlerThread 发布单曲,以简化此示例的工作。
public class MyLibrary extend HandlerThread {
private static Handler backgroundHandler;
private static Handler foregroundHandler;
private static MyLibrary myLibrary
private MyLibrary () {
super(MyLibrary.class.getSimpleName());
start();
}
public static MyLibrary getInstance() {
if (myLibrary == null) {
synchronized (MyLibrary.class) {
if (myLibrary == null) {
myLibrary = new MyLibrary();
}
}
}
return myLibrary;
}
public static WorkingTask with (Context context) {
//Just update, if there are null
if (foregroundHandler == null) {
foregroundHandler = new Handler(context.getMainLooper);
}
if (backgroundHandler == null) {
backgroundHandler = new Handler(getLooper);
}
return new WorkingTask();
}
public void getBackgroundHandler () {
return backgroundHandler;
}
public void getForegroundHandler () {
return foregroundHandler;
}
}
// ..........
public class WorkingTask {
private Runnable workingRunnable;
public performTask (Runnable run) {
this.workingRunnable = run;
return this;
}
public void execute () {
MyLibrary.getInstance().getBackgoundHandler()
.postRunnable(workingRunnable)
}
public void get () {
MyLibrary.getInstance().getForegroundHanlder()
.postRunnable(workingRunnable)
}
}
关于java - 如何使用 android 使用 FutureTask 或 BackgroundTask 实现 .get 功能?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38071528/
基本上我有以下代码片段, (let [task (FutureTask. fn) thr (Thread. task)] (.start thr) ;;wait for signa
我正在尝试将请求发送到服务器...直到请求没有响应我想执行一个打印整数的循环..问题是我的循环一直持续下去,如果我执行它直到 100 它会打印 100 个值并且如果直到 1000,它就会打印 1000
我正在创建一个 Java 应用程序。启动时,我的应用程序将下载所有必需的文件。我的应用程序将解析 XML 文件并从 XML 文件的 URL 下载文件。我希望我的应用程序“一步一步”下载文件,所以我使用
在 FutureTask.get 的 CancellationException 异常之后访问底层 Callable 的首选方法是什么? 我有以下代码- public class Ping imple
假设我用 Java 做了一些事情,比如: RemoteResponse response = null; try { FutureTask task new FutureTask(....);
我正在制作一些虚拟程序来了解这个 Java 类。我的定时任务调用了一个什么也不做的任务,在中断它之前给它 3 秒的时间。这是代码: FutureTask task = new FutureTask<>
new Thread(new Runnable() { public void run() { .............
这是一个非常简单的代码: FutureTask task = new FutureTask<>(new Callable(){ @Overrid
我创建了以下 FutureTask 方法来异步运行方法。 public FutureTask SendAggregateEventAsync(final com.Company.Pro
我已经实现了并发实践中描述的自定义取消逻辑。 Encapsulating nonstandard cancellation in a task with newTaskFor . 这很好用,我可以调用
我检查了 Oracle Java API,它提供了一些信息 FutureTask.isDone() 但我需要检查任务是否已完成或因任何错误而终止。isDone() 方法即使完成/终止也会返回。但我需要
我目前正试图了解如何 FutureTask.cancel(true)正在工作,这是官方文档的相关部分 If the task has already started, then the mayInte
我尝试实现一个内部方法,以便在新线程中执行以下代码 MyPojo result = null; final MyPojo result2 = result; FutureTask runnableTa
下面的代码无法编译(JDK 1.8.0_40),我无法理解为什么。 public abstract class BackgroundThread { private final Executo
我已经在网上搜索了一个星期了,但没有像这样的帖子 How do I get FutureTask to return after TimeoutException?似乎回答了我的问题。我从我的代码中提
我想为昂贵的路径查找任务设置一个 FutureTask。所以我创建了这个 Callable 类。 public class GetPath implements Callable> { pri
考虑在 Callable 实例中进行长时间运行的计算。 并且考虑到这个计算的结果可以有一定的精度取决于计算时间,即:如果任务将被取消,那么它应该返回取消之前到目前为止计算的内容(例如,我们有一个计算无
我遇到了这个令人沮丧的问题:我试图查看下面的代码中是否抛出 TimeoutException,但这种情况从未发生过。它总是打印当前时间 5 次并完成。 class MyTask1 implements
在我的可调用代码中,我使用信号通知向另一个线程通知多个结束行为。 Callable 对象与 Executor 中的 FutureTasks 一起排队。排队后也可能被取消。 现在,我的问题是,我至少依赖
我有一个应用程序,它定期提交要在专用线程中执行的任务。这些任务是 FutureTask并且线程只不过是一个无限循环,它在作业进入队列时执行作业,如果为空则进入 hibernate 状态。 有时我需要等
我是一名优秀的程序员,十分优秀!