看完了Flink的datasource、sink,也就把一头一尾给看完了,从数据流入到数据流出,缺少了中间的处理环节。 而flink的大头恰恰是只在这个中间环节,如下图: 中...

看完了Flink的datasource、sink,也就把一头一尾给看完了,从数据流入到数据流出,缺少了中间的处理环节。 而flink的大头恰恰是只在这个中间环节,如下图: 中...
上文学习了简单的map、flatmap、filter,在这里开始继续看keyBy及reduce keyBy 先看定义,通过keyBy,DataStream→KeyedStre...
@Hairger 我的意思是你讲的东西太没营养了。你既然都可以实现80%以上功能的线程池,讲原理带着线程池状态,核心态与非核心态线程工作的区别等等线程池的精髓去讲不是更好吗。 至于你讲的IOC的问题,那完全是你认为而已,控制反转和容器难道和反射没关系吗? 那我说你必须讲到类加载,否则就是不对的,是不是也可以? 这样较真有什么意义呢?
我在面试中经常会问的两个问题面试久了之后,发现自己每次都会问下面这两个问题。 线程池相关 问:你讲讲线程池的实现原理。 听到这个问题,小部分同学会很坦白的说,我平时用过线程池,但是没有了解过内部是怎么实...
@Hairger 线程池如何执行难道不是讲原理吗... 你讲了这么一堆很笼统,一点营养都没有啊。
我在面试中经常会问的两个问题面试久了之后,发现自己每次都会问下面这两个问题。 线程池相关 问:你讲讲线程池的实现原理。 听到这个问题,小部分同学会很坦白的说,我平时用过线程池,但是没有了解过内部是怎么实...
...你文章都不看就怼人的吗
我在面试中经常会问的两个问题面试久了之后,发现自己每次都会问下面这两个问题。 线程池相关 问:你讲讲线程池的实现原理。 听到这个问题,小部分同学会很坦白的说,我平时用过线程池,但是没有了解过内部是怎么实...
nid应该是线程id吧
jstack中的tid到底是什么意思呢我们经常见到类似的jstack信息 nid=0x1703 nid我们都知道是其实就是进程id。那tid呢,tid=0x00007fa63900c800 还这么大的一个数字 有...
基础 学习一个类,我们应该先从其字段开始。首先看看ThreadPoolExecutor对应的属性有哪些。 其中corePoolSize、maximumPoolSize、kee...
楼主测试过吗?
测试之后数组元素是volatile的
是我的测试方法有问题吗?
public class work2 {
public static void main(String[] args)
{
try
{
Test t = new Test();
t.start();
Thread.sleep(2000);
t.setRunning(false);
System.out.println("已赋值为false");
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
}
class Test extends Thread
{
private volatile boolean[] isRunning = new boolean[10];
public Test(){
isRunning[0]=true;
}
public void setRunning(boolean isRunning)
{
this.isRunning[0]=isRunning;
}
public void run()
{
System.out.println("进入run了");
while (isRunning[0]== true){};
System.out.println("线程被停止了");
}
}
如何保证数组元素的可见性问题 之前有小伙伴在星球提了这么一个问题 这篇文章时隔一两年,突然看到还是有点印象,文章中,我只是强硬的抛出了一个结论:虽然table变量被volatile修饰了,但里面的元...