diff --git a/src/main/java/com/jd/platform/async/worker/DependWrapper.java b/src/main/java/com/jd/platform/async/worker/DependWrapper.java index 4841c2b9220dbc3c57766ab07e089c273ed77642..3bdd2d29c856fe0509a71e6e69d045548d6a4d0b 100644 --- a/src/main/java/com/jd/platform/async/worker/DependWrapper.java +++ b/src/main/java/com/jd/platform/async/worker/DependWrapper.java @@ -3,6 +3,8 @@ package com.jd.platform.async.worker; import com.jd.platform.async.wrapper.WorkerWrapper; +import java.util.Objects; + /** * 对依赖的wrapper的封装 * @author wuweifeng wrote on 2019-12-20 @@ -49,6 +51,24 @@ public class DependWrapper { this.must = must; } + + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (!(o instanceof DependWrapper)) { + return false; + } + DependWrapper that = (DependWrapper) o; + return must == that.must && dependWrapper.equals(that.dependWrapper); + } + + @Override + public int hashCode() { + return Objects.hash(dependWrapper, must); + } + @Override public String toString() { return "DependWrapper{" +