Mirrors/FairEmail
1
0
Fork 0
mirror of https://github.com/M66B/FairEmail.git synced 2025-12-28 00:20:50 +01:00
Code Issues Packages Projects Releases Wiki Activity

Show hourglass when busy

Browse Source
This commit is contained in:
M66B
2019-06-09 13:11:33 +02:00
parent ed29b6e29b
commit 9382b98a63
4 changed files with 77 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
app/src/main/java/eu/faircode/email/SimpleTask.java
View File

@@ -20,6 +20,7 @@ package eu.faircode.email;
*/
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
@@ -31,6 +32,7 @@ import androidx.lifecycle.LifecycleObserver;
import androidx.lifecycle.LifecycleOwner;
import androidx.lifecycle.LifecycleService;
import androidx.lifecycle.OnLifecycleEvent;
import androidx.localbroadcastmanager.content.LocalBroadcastManager;
import java.util.ArrayList;
import java.util.List;
@@ -47,6 +49,8 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
private static final ExecutorService executor = Executors.newFixedThreadPool(
Runtime.getRuntime().availableProcessors(), Helper.backgroundThreadFactory);
static final String ACTION_TASK_COUNT = BuildConfig.APPLICATION_ID + ".ACTION_TASK_COUNT";
public void execute(Context context, LifecycleOwner owner, @NonNull Bundle args, @NonNull String name) {
run(context, owner, args, name);
}
@@ -71,10 +75,15 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
final Handler handler = new Handler();
// prevent garbage collection
int count;
synchronized (tasks) {
tasks.add(this);
count = tasks.size();
}
LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(context);
lbm.sendBroadcast(new Intent(ACTION_TASK_COUNT).putExtra("count", count));
try {
onPreExecute(args);
} catch (Throwable ex) {
@@ -104,12 +113,12 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
Lifecycle.State state = owner.getLifecycle().getCurrentState();
if (state.equals(Lifecycle.State.DESTROYED)) {
// No delivery
cleanup();
cleanup(context);
} else if (state.isAtLeast(Lifecycle.State.RESUMED)) {
// Inline delivery
Log.i("Deliver task " + name);
deliver();
cleanup();
cleanup(context);
} else
owner.getLifecycle().addObserver(new LifecycleObserver() {
@OnLifecycleEvent(Lifecycle.Event.ON_RESUME)
@@ -118,7 +127,7 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
Log.i("Resume task " + name);
owner.getLifecycle().removeObserver(this);
deliver();
cleanup();
cleanup(context);
}
@OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
@@ -126,7 +135,7 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
// No delivery
Log.i("Destroy task " + name);
owner.getLifecycle().removeObserver(this);
cleanup();
cleanup(context);
}
});
}
@@ -154,11 +163,16 @@ public abstract class SimpleTask<T> implements LifecycleObserver {
});
}
private void cleanup() {
private void cleanup(Context context) {
int count;
synchronized (tasks) {
tasks.remove(this);
Log.i("Remaining tasks=" + tasks.size());
count = tasks.size();
}
LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(context);
lbm.sendBroadcast(new Intent(ACTION_TASK_COUNT).putExtra("count", count));
Log.i("Remaining tasks=" + count);
}
protected void onPreExecute(Bundle args) {