mirror/FairEmail
1
0
Fork 0
mirror of https://github.com/M66B/FairEmail.git synced 2024-12-25 17:27:00 +00:00
Code Issues Releases Wiki Activity

Sync stop operations

Browse source
This commit is contained in:
M66B 2022-04-18 12:37:28 +02:00
parent 025aefea7d
commit 092b16a6dc
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
app/src/main/java/eu/faircode/email/ServiceSynchronize.java
View file

@ -74,8 +74,10 @@ import java.util.LinkedHashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import javax.mail.AuthenticationFailedException; import javax.mail.AuthenticationFailedException;
import javax.mail.Folder; import javax.mail.Folder;
@ -2321,7 +2323,7 @@ public class ServiceSynchronize extends ServiceBase implements SharedPreferences
Log.i(account.name + " stop watching operations"); Log.i(account.name + " stop watching operations");
final TwoStateOwner _owner = cowner.value; final TwoStateOwner _owner = cowner.value;
if (_owner != null) { if (_owner != null) {
cowner.value = null; final CountDownLatch latch = new CountDownLatch(1);
getMainHandler().post(new RunnableEx("observe#stop") { getMainHandler().post(new RunnableEx("observe#stop") {
@Override @Override
public void delegate() { public void delegate() {
@ -2329,9 +2331,17 @@ public class ServiceSynchronize extends ServiceBase implements SharedPreferences
_owner.destroy(); _owner.destroy();
} catch (Throwable ex) { } catch (Throwable ex) {
Log.e(ex); Log.e(ex);
} finally {
latch.countDown();
} }
} }
}); });
try {
latch.await(5000L, TimeUnit.MILLISECONDS);
} catch (InterruptedException ex) {
Log.w(ex);
}
} }
// Stop executing operations // Stop executing operations