From 7444c2b1f281b5b147717ba2a2ed6798c66a057b Mon Sep 17 00:00:00 2001
From: Keuin <keuinx@gmail.com>
Date: Mon, 27 Apr 2020 17:42:07 +0800
Subject: Resized the logo to reduce plugin size. Refactored code for a better
 implementation of async and blocking task.

---
 .../abstracts/AbstractBlockingOperation.java       | 58 ++++++++++++++++++++++
 1 file changed, 58 insertions(+)
 create mode 100644 src/main/java/com/keuin/kbackupfabric/operation/abstracts/AbstractBlockingOperation.java

(limited to 'src/main/java/com/keuin/kbackupfabric/operation/abstracts/AbstractBlockingOperation.java')

diff --git a/src/main/java/com/keuin/kbackupfabric/operation/abstracts/AbstractBlockingOperation.java b/src/main/java/com/keuin/kbackupfabric/operation/abstracts/AbstractBlockingOperation.java
new file mode 100644
index 0000000..de672cd
--- /dev/null
+++ b/src/main/java/com/keuin/kbackupfabric/operation/abstracts/AbstractBlockingOperation.java
@@ -0,0 +1,58 @@
+package com.keuin.kbackupfabric.operation.abstracts;
+
+import com.keuin.kbackupfabric.operation.abstracts.i.Blocking;
+
+public abstract class AbstractBlockingOperation extends AbstractSerializedOperation implements Blocking {
+
+    private static final Object sync = new Object();
+    private static boolean isBlocking = false;
+    private boolean wasBlocked = false;
+    private boolean noUnblocking = false;
+
+    @Override
+    protected final boolean operate() {
+        synchronized (sync) {
+            if (isBlocking) {
+                System.out.println("blocked.");
+                wasBlocked = true;
+                return false;
+            } else {
+                System.out.println("not blocked.");
+                wasBlocked = false;
+                isBlocking = true;
+            }
+        }
+        boolean exitCode = blockingContext();
+        if (!noUnblocking)
+            isBlocking = false;
+        return exitCode;
+    }
+
+    public final boolean isBlocked() {
+        return wasBlocked;
+    }
+
+    protected final void block(boolean blockState) {
+        isBlocking = blockState;
+    }
+
+    protected void noUnblocking(boolean b) {
+        noUnblocking = b;
+    }
+
+    protected boolean blockAndGet() {
+        synchronized (sync) {
+            boolean b = isBlocking;
+            isBlocking = true;
+            return b;
+        }
+    }
+
+    /**
+     * Implement your blocked operation here.
+     *
+     * @return the stat code.
+     */
+    protected abstract boolean blockingContext();
+
+}
-- 
cgit v1.2.3