Sha*_*ank -1 java collections concurrency multithreading
根据我的理解,如果一个线程已经在访问它,Vector 应该阻止其他线程的整个集合。我在尝试着
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;
import java.util.concurrent.CopyOnWriteArrayList;
public class MyTest1{
// static ArrayList<String> l1 = new ArrayList<>(Arrays.asList("A", "B", "C"));
static Vector<String> l1 = new Vector<>(Arrays.asList("A", "B", "C"));
// static List<String> l1 = Collections.synchronizedList(Arrays.asList("A", "B", "C"));
public static void main(String[] args) {
Thread t1 = new Thread(new MyThread1());
Thread t2 = new Thread(new MyThread2());
t1.start();
t2.start();
System.out.println(Thread.currentThread() + "adding X " + l1.add("X"));
System.out.println(Thread.currentThread() + "adding Y " + l1.add("Y"));
System.out.println(Thread.currentThread() + "adding Z " + l1.add("Z"));
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(l1);
}
static class MyThread1 implements Runnable{
@Override
public void run() {
System.out.println(Thread.currentThread() + "adding D " + l1.add("D"));
System.out.println(Thread.currentThread() + "adding E " + l1.add("E"));
System.out.println(Thread.currentThread() + "adding F " + l1.add("F"));
}
}
static class MyThread2 implements Runnable{
@Override
public void run() {
System.out.println(Thread.currentThread() + "removing A " + l1.remove("A"));
System.out.println(Thread.currentThread() + "removing B " + l1.remove("B"));
System.out.println(Thread.currentThread() + "removing C " + l1.remove("C"));
}
}
}
Run Code Online (Sandbox Code Playgroud)
输出:
Thread[main,5,main]adding X true
Thread[Thread-1,5,main]removing A true
Thread[Thread-1,5,main]removing B true
Thread[Thread-0,5,main]adding D true
Thread[Thread-1,5,main]removing C true
Thread[main,5,main]adding Y true
Thread[Thread-0,5,main]adding E true
Thread[main,5,main]adding Z true
Thread[Thread-0,5,main]adding F true
[X, D, Y, E, Z, F]
Run Code Online (Sandbox Code Playgroud)
输出不应该是这样的。对于特定线程,它应该是 3 个连续的添加或删除。我在这里缺少什么?请帮忙。
在有问题的代码中,
add
和remove
操作单独(独立)同步 - 在任何给定时间,只能在对象上执行此操作之一如果您需要跨一组操作进行同步,
ArrayList
与同步一起使用时应该没问题import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
class MyTest1 {
static List<String> l1 = new ArrayList<>(Arrays.asList("A", "B", "C"));
public static void main(String[] args) {
Thread t1 = new Thread(() -> {
synchronized (l1) {
System.out.println(Thread.currentThread() + "removing A " + l1.remove("A"));
System.out.println(Thread.currentThread() + "removing B " + l1.remove("B"));
System.out.println(Thread.currentThread() + "removing C " + l1.remove("C"));
}
});
Thread t2 = new Thread(() -> {
synchronized (l1) {
System.out.println(Thread.currentThread() + "removing A " + l1.remove("A"));
System.out.println(Thread.currentThread() + "removing B " + l1.remove("B"));
System.out.println(Thread.currentThread() + "removing C " + l1.remove("C"));
}
});
t1.start();
t2.start();
synchronized (l1) {
System.out.println(Thread.currentThread() + "adding X " + l1.add("X"));
System.out.println(Thread.currentThread() + "adding Y " + l1.add("Y"));
System.out.println(Thread.currentThread() + "adding Z " + l1.add("Z"));
}
try {
t1.join();
t2.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(l1);
}
}
Run Code Online (Sandbox Code Playgroud)