java - 如何在这个非线程安全的数组列表类上引发竞争条件?
问题描述
我正在尝试构建一个线程安全的arraylist类
import java.util.stream.*;
import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class LongArrayListUnsafe {
public static void main(String[] args) {
LongArrayList dal1 = LongArrayList.withElements();
ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
for (int i=0; i<1000; i++) {
executorService.execute(new Runnable() {
public void run() {
for (int i=0; i<10; i++)
dal1.add(i);
}
});}
System.out.println("Using toString(): " + dal1);
for (int i=0; i<dal1.size(); i++)
System.out.println(dal1.get(i));
System.out.println(dal1.size());} }
class LongArrayList {
private long[] items;
private int size;
public LongArrayList() {
reset();
}
public static LongArrayList withElements(long... initialValues){
LongArrayList list = new LongArrayList();
for (long l : initialValues) list.add( l );
return list;
}
// reset me to initial
public void reset(){
items = new long[2];
size = 0;
}
// Number of items in the double list
public int size() {
return size;
}
// Return item number i
public long get(int i) {
if (0 <= i && i < size)
return items[i];
else
throw new IndexOutOfBoundsException(String.valueOf(i));
}
// Replace item number i, if any, with x
public long set(int i, long x) {
if (0 <= i && i < size) {
long old = items[i];
items[i] = x;
return old;
} else
throw new IndexOutOfBoundsException(String.valueOf(i));}
// Add item x to end of list
public LongArrayList add(long x) {
if (size == items.length) {
long[] newItems = new long[items.length * 2];
for (int i=0; i<items.length; i++)
newItems[i] = items[i];
items = newItems;
}
items[size] = x;
size++;
return this;
}
public String toString() {
return Arrays.stream(items, 0,size)
.mapToObj( Long::toString )
.collect(Collectors.joining(", ", "[", "]"));
}
}
“Longaraylist”类只是一个非线程安全列表的类,这是我稍后想要操作以使其成为线程安全的类。现在困扰我的是 main 中的驱动程序代码,我正在创建一个 executorservice,并且我正在向它提交一堆任务。在我看来,使用这个非线程安全的类,这应该会引入一些竞争条件,并且“大小”变量至少应该被破坏。但是每次我运行这段代码时,它都会完美运行。我最后打印的大小完全对应于调用 add() 的次数。
我能做些什么不同的事情?也许我使用 executorservice 错误?我还将感谢任何其他测试此类线程安全性的提示。谢谢你
解决方案
推荐阅读
- java - 如何一次向 BehaviorSubject 提供多个值
- angular - 将数组表达式转换为对象角度
- javascript - 尝试使用自定义函数将单元格条目用作数组参数来找出 Google 表格的行为?
- javascript - .Vue 组件不会在 laravel 中的每条新消息上刷新
- awk - awk - 通过变量搜索模式
- wordpress - 如何将 wordpress 项目从一台服务器传输到另一台服务器子目录?
- c - C - 当输入不是 int 时,提示用户输入有效的 int 会导致无限循环
- mysql - 使用微软的cmd(或powershell)无法将汉字插入MySQL
- javascript - React:具有连接功能的导出功能
- spring - Mybatis mapper.xml中如何使用Rowbounds类?