Java 8：在addall兩次後刪除重複，可能出現併發問題？

Question

我知道這是一個老話題，但以下奇怪的測試用例看起來很新，至少對我自己來說，先謝謝了！

問題： 我期待重複項目將被刪除，但結果不穩定，即如果運行多次，則結果不一樣。這些代碼背後可能存在併發問題。

如果一個接一個地添加重複的項目，那麼代碼是好的。 但是，如果使用addall兩次（僅用於測試目的），那麼期望的結果是不穩定的。

import java.util.ArrayList; 
import java.util.Comparator; 
import java.util.List; 
import java.util.Objects; 
import java.util.concurrent.ConcurrentSkipListSet; 
import java.util.stream.Collectors; 

public class TestJava { 

    public static void main(String[] args) { 
     List<TestObj> result = new ArrayList<>(); 

     List<TestObj> tempList = new ArrayList<>(); 
     List<TestObj> tempList2 = new ArrayList<>(); 
     List<TestObj> tempResult = new ArrayList<>(); 

     int size = 3; 

     for (int i = 0; i < size; i++) { 
      TestObj testObj = new TestObj(); 
      testObj.setField1("555"); 
      testObj.setField2("" + i); 
      tempList.add(testObj); 

      TestObj testObj2 = new TestObj(); 
      testObj2.setField1("555"); 
      testObj2.setField2("" + i); 
      tempList2.add(testObj2); 

      // tempResult.add(testObj); // <-- if use this, then no concurrency issue 
      // tempResult.add(testObj2); 
     } 

     tempResult.addAll(tempList); 
     tempResult.addAll(tempList2); 

     System.out.println("expecting 6, actual = " + tempResult.size()); 

     FilterComparator comp = new FilterComparator(); 

     result = tempResult.stream() // 
       .filter(new ConcurrentSkipListSet<>(comp)::add)// 
       .collect(Collectors.toList()); 
     System.out.println("expecting 3, actual = " + result.size()); // <-- Here, looks like there is a concurrency issue! 
    } 

    public static class TestObj { 
     private String field1; 
     private String field2; 
     private String field3; 

     public String getField1() { 
      return field1; 
     } 

     public void setField1(String field1) { 
      this.field1 = field1; 
     } 

     public String getField2() { 
      return field2; 
     } 

     public void setField2(String field2) { 
      this.field2 = field2; 
     } 

     public String getField3() { 
      return field3; 
     } 

     public void setField3(String field3) { 
      this.field3 = field3; 
     } 

    } 

    public static class FilterComparator implements Comparator<TestObj> { 
     public int compare(TestObj o1, TestObj o2) { 
      if (compareIfSameString(o1.getField1(), o2.getField1()) // 
        && compareIfSameString(o1.getField2(), o2.getField2()) // 
      ) { 
       return 0; 
      } 

      return 1; 
     } 
    } 

    public static boolean compareIfSameString(String oldValue, String newValue) { 
     if (isReallyEmptyOrNull(oldValue) && isReallyEmptyOrNull(newValue)) { 
      return true; 
     } 

     return Objects.equals(oldValue, newValue); 
    } 

    public static boolean isReallyEmptyOrNull(String value) { 
     return value == null || "".equals(value.trim()); 
    } 

} 

更新：對於稍後參考 感謝JB Nizet的評論。我修改比較如下，一切都很好！

public static class FilterComparator implements Comparator<TestObj> { 
    public int compare(TestObj o1, TestObj o2) { 
     if (o1.getField1() == null) { 
      if (o2.getField1() != null) { 
       return o2.getField1().compareTo(o1.getField1()); 
      } 
     } else if (o1.getField1().compareTo(o2.getField1()) != 0) { 
      return o1.getField1().compareTo(o2.getField1()); 
     } 

     if (o1.getField2() == null) { 
      if (o2.getField2() != null) { 
       return o2.getField2().compareTo(o1.getField2()); 
      } 
     } else if (o1.getField2().compareTo(o2.getField2()) != 0) { 
      return o1.getField2().compareTo(o2.getField2()); 
     } 

     if (o1.getField3() == null) { 
      if (o2.getField3() != null) { 
       return o2.getField3().compareTo(o1.getField3()); 
      } 
     } else if (o1.getField3().compareTo(o2.getField3()) != 0) { 
      return o1.getField3().compareTo(o2.getField3()); 
     } 
     return 0; 

    } 
} 

Answer 1

你比較被錯誤執行，檢查這些值的反轉，每次你會得到不只是相同的結果，但發現所期望的第二個值是2不3 ;-)

public static class FilterComparator implements Comparator<TestObj> { 

     public int compare(TestObj o1, TestObj o2) { 
      if (compareIfSameString(o1.getField1(), o2.getField1()) // 
        && compareIfSameString(o1.getField2(), o2.getField2()) // 
      ) { 
       return 1;// here 
      } 

      return 0; //and here 
     } 
    }