分享今天遇到的三个代码设计

30个人抢100分钱
第1抢到了4分, 还剩下96分, 区间是[1, 6.666667]
第2抢到了5分, 还剩下91分, 区间是[1, 6.620690]
第3抢到了2分, 还剩下89分, 区间是[1, 6.500000]
第4抢到了1分, 还剩下88分, 区间是[1, 6.592593]
第5抢到了3分, 还剩下85分, 区间是[1, 6.769231]
第6抢到了4分, 还剩下81分, 区间是[1, 6.800000]
第7抢到了4分, 还剩下77分, 区间是[1, 6.750000]
第8抢到了1分, 还剩下76分, 区间是[1, 6.695652]
第9抢到了5分, 还剩下71分, 区间是[1, 6.909091]
第10抢到了4分, 还剩下67分, 区间是[1, 6.761905]
第11抢到了5分, 还剩下62分, 区间是[1, 6.700000]
第12抢到了5分, 还剩下57分, 区间是[1, 6.526316]
第13抢到了6分, 还剩下51分, 区间是[1, 6.333333]
第14抢到了4分, 还剩下47分, 区间是[1, 6.000000]
第15抢到了1分, 还剩下46分, 区间是[1, 5.875000]
第16抢到了3分, 还剩下43分, 区间是[1, 6.133333]
第17抢到了1分, 还剩下42分, 区间是[1, 6.142857]
第18抢到了4分, 还剩下38分, 区间是[1, 6.461538]
第19抢到了2分, 还剩下36分, 区间是[1, 6.333333]
第20抢到了5分, 还剩下31分, 区间是[1, 6.545455]
第21抢到了1分, 还剩下30分, 区间是[1, 6.200000]
第22抢到了6分, 还剩下24分, 区间是[1, 6.666667]
第23抢到了1分, 还剩下23分, 区间是[1, 6.000000]
第24抢到了4分, 还剩下19分, 区间是[1, 6.571429]
第25抢到了3分, 还剩下16分, 区间是[1, 6.333333]
第26抢到了4分, 还剩下12分, 区间是[1, 6.400000]
第27抢到了5分, 还剩下7分, 区间是[1, 6.000000]
第28抢到了1分, 还剩下6分, 区间是[1, 4.666667]
第29抢到了3分, 还剩下3分, 区间是[1, 6.000000]
最后一个已经抢完, 金额为3
已经抢完, 总共金额为100分

  /**
   * 花色的list
   */
  List<String> colors = Lists.newArrayList("黑桃", "红心", "梅花", "方块");

  /**
   * 字面值的list. 使用双流合并, 因为很懒不愿意打2-10, 就用IntStream来生成了
   */
  List<String> numbers = Stream.concat(IntStream.rangeClosed(2, 10).mapToObj(String::valueOf),
      Stream.of("A", "J", "K", "Q")).collect(Collectors.toList());

  @Test
  public void collectionShuffleTest() {
    // 进行组合
    List<String> result = colors.stream()
        .flatMap(color -> numbers.stream().map(number -> color + number))
        .collect(Collectors.toList());

    // 进行打乱
    Collections.shuffle(result);
    // 在console输出(为了方便看, 转成pretty的json)
    System.out.println(JSON.toJSONString(result, SerializerFeature.PrettyFormat));
  }

  @Test
  public void randomSwapTest() {
    // 进行组合
    List<String> result = colors.stream()
        .flatMap(color -> numbers.stream().map(number -> color + number))
        .collect(Collectors.toList());

    // 进行打乱52次
    for (int count = result.size(); count > 0; count--) {
      // 生成对换的随机数
      int site1 = RandomUtil.randomInt(0, result.size() - 1);
      int site2 = RandomUtil.randomInt(0, result.size() - 1);
      // 进行wap
      String temp = result.get(site1);
      result.set(site1, result.get(site2));
      result.set(site2, temp);
    }

    // 在console输出(为了方便看, 转成pretty的json)
    System.out.println(JSON.toJSONString(result, SerializerFeature.PrettyFormat));
  }

/**
 * Swaps the two specified elements in the specified array.
 */
private static void swap(Object[] arr, int i, int j) {
    Object tmp = arr[i];
    arr[i] = arr[j];
    arr[j] = tmp;
}

@Test
@SuppressWarnings("all")
public void parallelStreamTest() {
  // 先构建扑克牌
  List<String> rawList = colors.stream()
      .flatMap(color -> numbers.stream().map(number -> color + number))
      .collect(Collectors.toList());

  // 创建容器
  List<String> result = new ArrayList<>(sumCount);

  // 使用副作用进行并行添加到容器中
  rawList.parallelStream().forEach(result::add);

  // 在console输出(为了方便看, 转成pretty的json)
  System.out.println(JSON.toJSONString(result, SerializerFeature.PrettyFormat));
  System.out.println(result.size());
}

 @Test
  @SneakyThrows
  @SuppressWarnings("all")
  public void multithreadingTest() {
    // 把花色先分好
    List<Queue<String>> rawList = colors.stream()
        .map(color -> numbers.stream().map(number -> color + number)
            .collect(Collectors.toCollection(LinkedList::new)))
        .collect(Collectors.toList());

    List<String> result = new ArrayList<>(sumCount);
    // 偷懒使用jdk自带的线程池
    ExecutorService executor = Executors.newCachedThreadPool();
    CountDownLatch countDownLatch = new CountDownLatch(colorCount);

    for (int i = 0; i < colorCount; i++) {
      int current = i;
      ReentrantLock lock = new ReentrantLock();
      for (int count = 1; count <= numberCount; count++) {
        executor.execute(() -> {
          lock.lock();
          if (CollectionUtil.isNotEmpty(rawList.get(current))) {
            result.add(rawList.get(current).poll());
          }
          lock.unlock();
        });
      }
      countDownLatch.countDown();
    }

    // 防止主线程提前结束
    countDownLatch.await(10, TimeUnit.SECONDS);

    // 在console输出(为了方便看, 转成pretty的json)
    System.out.println(JSON.toJSONString(result, SerializerFeature.PrettyFormat));
    System.out.println(result.size());
  }