对象共享 package com.git.poan.multithreadpractice; public class NoVisibility { private static boolean ready; private static int number; public static void main(String[] args) throws InterruptedException { Thread readThread = new Thread(() -> {...
Read More线程安全问题？ 原书里面给的定义：某个类的行为与其规范完全一致。（反过来说，就是竞态条件下，类的方法不会出现预料以外的结果） 那么什么时候会出现类的行为与其规范不一致？ 竞态 Java提供了多线程，也就是说任意方法都会被并发访问，但又不是所有方法都会被多个线程并发访问到（如果以我自己经验来说，也就单例的getInstance方法有可能会被多线程并发调用）； 所以第一步应该明确自己业务中哪些方法的调用会存在竞态； 竞态下资源更新 如果这个方法存在竞态，而该方法本身又不涉及到更新操作，比如： pubulic int get() { return 1; } 这个方法就算被N个线程并发访问，也不会有安全问题。。。 如果返回的是一个final类型的，也不会有安全问题。。。 如果一个方法本身涉及到一个资源的更新（类中某个变量的赋值、修改之类的操作），出现了竞态，那么就有可能出现线程安全问题； 比如前一篇中的情况就是线程不安全的； 竞态下不可避免的资源更新——同步 如果一个方法存在竞态，可以尽量将更新的资源放到外面；如果不可避免，则需要使用同步； 在前一篇里面使用了synchronized实现同步，实际上还有volatile、Atomic、ReentrantLock同步机制。
Read More自加操作多线程读取时的问题 在《JAVA并发编程实战》中，解释了i++在多线程情况下的坑 我这里稍微模拟了一下： package com.git.poan.multithreadpractice; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class UnsafeSequence { private int val; public int getNextVal() { return ++val;// 原书使用的是val++；感觉这样效果不直观 ，我用++val } public static void main(String[] args)...
Read More参考 zookeeper与paxos的相似点： leader给予follwer提供参考值 leader提交建议之前会等待follwer的通知 每个请求建议（应该是zxid），会包含一个纪元号，和Paxos的投票选举类似 但是其主要差距在于，zab主机宕机备份恢复为主，而不是状态机副本为主。 primay-backup和state machine replication的区别 state machine replication能保证每次接收到的有序请求，都能得到正确的处理 primary-backup系统比如zookeeper，副本可以按增量式状态排序（zxid前32位表示所属会议，后32位是递增数字）， 是由主要副本（应该是leader）生成发送给其他follwer的，state machine replication不一样，如果主机宕了，客户端就找不到可以处理请求的机器了。 zookeeper专门的一致性算法——zab zab是zookeeper atomic broadcast 的缩写；在以上两种概念之下，zab对于state machine repliacation的具体实现方式： 对象设计： leader： 整个zk会议中，负责更新状态的服务；兼职发起投票 leaner： follower：处理客户端的请求，并可以参与投票和选举 observer：处理客户端的请求，但是不可以参与投票和选举 zab的两种模式：...
Read More在一次微服务中遇到过GC长时间停顿，jconsole中显示堆内存一直飙升从不下降的过程，这里进行一下模拟； 开启JMX监控 在springboot中可以很方便添加jmx启动配置： @Configuration class ConfigureRMI { @Value("${jmx.rmi.hostname:localhost}") private String rmiHost; @Value("${jmx.rmi.port:5000}") private Integer rmiPort; @Bean public RmiRegistryFactoryBean rmiRegistry() { final RmiRegistryFactoryBean rmiRegistryFactoryBean = new RmiRegistryFactoryBean(); rmiRegistryFactoryBean.setPort(rmiPort); rmiRegistryFactoryBean.setAlwaysCreate(true); return rmiRegistryFactoryBean;...
Read More