From be8a596200c5e6010af4a442b3fa2932b37f1cff Mon Sep 17 00:00:00 2001 From: Damyan Ivanov Date: Wed, 25 Aug 2021 23:25:31 +0300 Subject: [PATCH] add an async runner class for general tasks supposed to replace AsyncTask usage --- .../async/GeneralBackgroundTasks.java | 62 +++++++++++++++++++ 1 file changed, 62 insertions(+) create mode 100644 app/src/main/java/net/ktnx/mobileledger/async/GeneralBackgroundTasks.java diff --git a/app/src/main/java/net/ktnx/mobileledger/async/GeneralBackgroundTasks.java b/app/src/main/java/net/ktnx/mobileledger/async/GeneralBackgroundTasks.java new file mode 100644 index 00000000..11092192 --- /dev/null +++ b/app/src/main/java/net/ktnx/mobileledger/async/GeneralBackgroundTasks.java @@ -0,0 +1,62 @@ +/* + * Copyright © 2021 Damyan Ivanov. + * This file is part of MoLe. + * MoLe is free software: you can distribute it and/or modify it + * under the term of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your opinion), any later version. + * + * MoLe is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License terms for details. + * + * You should have received a copy of the GNU General Public License + * along with MoLe. If not, see . + */ + +package net.ktnx.mobileledger.async; + +import net.ktnx.mobileledger.utils.Misc; + +import org.jetbrains.annotations.NotNull; +import org.jetbrains.annotations.Nullable; + +import java.util.concurrent.Executor; +import java.util.concurrent.Executors; + +public class GeneralBackgroundTasks { + private static final Executor runner = Executors.newCachedThreadPool(); + public static void run(@NotNull Runnable runnable) { + runner.execute(runnable); + } + public static void run(@NotNull Runnable runnable, @NotNull Runnable onSuccess) { + runner.execute(() -> { + runnable.run(); + onSuccess.run(); + }); + } + public static void run(@NotNull Runnable runnable, @Nullable Runnable onSuccess, + @Nullable ErrorCallback onError, @Nullable Runnable onDone) { + runner.execute(() -> { + try { + runnable.run(); + if (onSuccess != null) + Misc.onMainThread(onSuccess); + } + catch (Exception e) { + if (onError != null) + Misc.onMainThread(() -> onError.error(e)); + else + throw e; + } + finally { + if (onDone != null) + Misc.onMainThread(onDone); + } + }); + } + public static abstract class ErrorCallback { + abstract void error(Exception e); + } +} -- 2.39.2