流处理,这里用netcat来完成
package com.smalltiger.flinkWCimport org.apache.flink.api.java.utils.ParameterTool
import org.apache.flink.streaming.api.scala._/*** Created by smalltiger on 2019/11/6.* flink基于流处理的一个WordCount统计*/
object Stre…
1、CAS底层原理?
自旋锁(cas思想)unsafe类,保证原子性靠的是unsafe类
1.首先可以看到:
atomicInteger.getAndIncrement();getAndIncrement()的底层是 public final int getAndIncrement() {return unsafe.getAndAddInt(this, valueOffset,…