• AtomicIntegerArray
  • AtomicLongArray
  • AtomicReferenceArray

数组安全性测试类

  1. public class Test39 {
  3.     public static void main(String[] args) {
  4.         demo(
  5.                 ()->new int[10],
  6.                 (array)->array.length,
  7.                 (array, index) -> array[index]++,
  8.                 array-> System.out.println(Arrays.toString(array))
  9.         );
  11.         demo(
  12.                 ()-> new AtomicIntegerArray(10),
  13.                 (array) -> array.length(),
  14.                 (array, index) -> array.getAndIncrement(index),
  15.                 array -> System.out.println(array)
  16.         );
  17.     }
  19.     /**
  20.      参数1，提供数组、可以是线程不安全数组或线程安全数组
  21.      参数2，获取数组长度的方法
  22.      参数3，自增方法，回传 array, index
  23.      参数4，打印数组的方法
  24.      */
  25.     // supplier 提供者 无中生有  ()->结果
  26.     // function 函数   一个参数一个结果   (参数)->结果  ,  BiFunction (参数1,参数2)->结果
  27.     // consumer 消费者 一个参数没结果  (参数)->void,      BiConsumer (参数1,参数2)->
  28.     private static <T> void demo(
  29.             Supplier<T> arraySupplier,
  30.             Function<T, Integer> lengthFun,
  31.             BiConsumer<T, Integer> putConsumer,
  32.             Consumer<T> printConsumer ) {
  33.         List<Thread> ts = new ArrayList<>();
  34.         T array = arraySupplier.get();
  35.         int length = lengthFun.apply(array);
  36.         for (int i = 0; i < length; i++) {
  37.             // 每个线程对数组作 10000 次操作
  38.             ts.add(new Thread(() -> {
  39.                 for (int j = 0; j < 10000; j++) {
  40.                     putConsumer.accept(array, j%length);
  41.                 }
  42.             }));
  43.         }
  45.         ts.forEach(t -> t.start()); // 启动所有线程
  46.         ts.forEach(t -> {
  47.             try {
  48.                 t.join();
  49.             } catch (InterruptedException e) {
  50.                 e.printStackTrace();
  51.             }
  52.         });     // 等所有线程结束
  53.         printConsumer.accept(array);
  54.     }
  55. }
  1. demo(
  2.  ()-> new AtomicIntegerArray(10),
  3.  (array) -> array.length(),
  4.  (array, index) -> array.getAndIncrement(index),
  5. array -> System.out.println(array)
  6. );