From 6e2d1cbf4d61b6444f26c67854df345fe8e67bc4 Mon Sep 17 00:00:00 2001
From: wuweifeng10 <Wu@0396110>
Date: Mon, 20 Apr 2020 11:52:44 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E4=B8=80=E4=B8=AA=E9=87=8D=E8=BD=BD?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../platform/async/wrapper/WorkerWrapper.java | 24 +++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java b/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
index 2c80b16..25896a0 100755
--- a/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
+++ b/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
@@ -433,6 +433,30 @@ public class WorkerWrapper<T, V> {
         this.needCheckNextWrapperResult = needCheckNextWrapperResult;
     }
 
+    @Override
+    public boolean equals(Object o) {
+        if (this == o)  {
+            return true;
+        }
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        WorkerWrapper<?, ?> that = (WorkerWrapper<?, ?>) o;
+        return needCheckNextWrapperResult == that.needCheckNextWrapperResult &&
+                Objects.equals(param, that.param) &&
+                Objects.equals(worker, that.worker) &&
+                Objects.equals(callback, that.callback) &&
+                Objects.equals(nextWrappers, that.nextWrappers) &&
+                Objects.equals(dependWrappers, that.dependWrappers) &&
+                Objects.equals(state, that.state) &&
+                Objects.equals(workResult, that.workResult);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(param, worker, callback, nextWrappers, dependWrappers, state, workResult, needCheckNextWrapperResult);
+    }
+
     public static class Builder<W, C> {
         /**
          * worker将来要处理的param