185186187188189190191192193194195
} public void testRetainAll() { final AckCollector ac=new AckCollector(list); List<Address> members=Arrays.asList(one, two, three); ac.retainAll(members); System.out.println("ac=" + ac); assert ac.size() == 3; new Thread() { public void run() {
214215216217218219220221222223224
System.out.println("ac = " + ac); new Thread() { public void run() { Util.sleep(1000); ac.retainAll(Arrays.asList(five)); System.out.println("ac=" + ac); } }.start(); boolean received_all=ac.waitForAllAcks(30000);