treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixing bug wit waiter imap

Browse source
This commit is contained in:
psemenkov 2022-11-14 14:01:39 +03:00
parent aa103cbf5f
commit badbe47bc4
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
clearing-parent/account-service/src/test/java/ru/spcex/clearing/account/utils/ImapEvent.java
View file

@ -5,6 +5,8 @@ import com.hazelcast.map.listener.EntryAddedListener;
import com.hazelcast.map.listener.EntryRemovedListener; import com.hazelcast.map.listener.EntryRemovedListener;
import com.hazelcast.map.listener.EntryUpdatedListener; import com.hazelcast.map.listener.EntryUpdatedListener;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
public class ImapEvent<T> { public class ImapEvent<T> {
@ -37,6 +39,14 @@ public class ImapEvent<T> {
} }
public void waitHappened() throws InterruptedException { public void waitHappened() throws InterruptedException {
//running timer task as daemon thread
Timer timer = new Timer(true);
timer.scheduleAtFixedRate(new TimerTask() {
@Override
public void run() {
checkEventHappened.set(true);//если что-то пойдет не так не тормозить основной поток
}
}, 0, 60 * 1000);
synchronized (checkEventHappened) { synchronized (checkEventHappened) {
while (!checkEventHappened.get()) { while (!checkEventHappened.get()) {
checkEventHappened.wait(100); checkEventHappened.wait(100);