Async review

Author: rjeberhard

src/main/java/oracle/kubernetes/operator/work/FiberGate.java

@@ -55,17 +55,18 @@ public void onThrowable(Packet packet, Throwable throwable) {
 
   private static class WaitForOldFiberStep extends Step {
     private final AtomicReference<Fiber> old;
-    private WaitForOldFiberStep current;
+    private final AtomicReference<WaitForOldFiberStep> current;
 
     public WaitForOldFiberStep(Fiber old, Step next) {
       super(next);
       this.old = new AtomicReference<>(old);
-      current = this;
+      current = new AtomicReference<>(this);
     }
 
     @Override
     public NextAction apply(Packet packet) {
-      Fiber o = current != null ? current.old.getAndSet(null) : null;
+      WaitForOldFiberStep c = current.get();
+      Fiber o = c != null ? c.old.getAndSet(null) : null;
       if (o == null) {
         return doNext(packet);
       }
@@ -74,13 +75,13 @@ public NextAction apply(Packet packet) {
         boolean isWillCall = o.cancelAndExitCallback(true, new ExitCallback() {
           @Override
           public void onExit() {
-            current = o.getSPI(WaitForOldFiberStep.class);
+            current.set(o.getSPI(WaitForOldFiberStep.class));
             fiber.resume(packet);
           }
         });
 
         if (!isWillCall) {
-          current = o.getSPI(WaitForOldFiberStep.class);
+          current.set(o.getSPI(WaitForOldFiberStep.class));
           fiber.resume(packet);
         }
       });

src/main/java/oracle/kubernetes/operator/work/Packet.java

@@ -5,17 +5,17 @@
 
 import java.util.AbstractMap;
 import java.util.Collections;
-import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * Context of a single processing flow.  Acts as a map and as a registry of components.
  * 
  */
 public class Packet extends AbstractMap<String, Object> implements ComponentRegistry, ComponentEx {
-  private final Map<String, Component> components = new HashMap<String, Component>();
-  private final Map<String, Object> delegate = new HashMap<String, Object>();
+  private final Map<String, Component> components = new ConcurrentHashMap<String, Component>();
+  private final Map<String, Object> delegate = new ConcurrentHashMap<String, Object>();
 
   public Packet() {}