<java并发编程实战>学习一
这本书的内容是什么?
本书提供了各种实用的设计规则,用于帮助开发人员创建安全的和高性能的并发类。
什么类是线程安全的?
当多个线程访问某个类时,这个类始终都能表现出正确的行为,那么就称这个类是线程安全的。
无状态的sevlet是线程安全的, 当无状态变为有状态时就是不安全的
@NotThreadSafe public class UnsafeCountingFactorizer extends GenericServlet implements Servlet { private long count = 0; public long getCount() { return count; } public void service(ServletRequest req, ServletResponse resp) { BigInteger i = extractFromRequest(req); BigInteger[] factors = factor(i); ++count;//破坏了线程的安全性 ,非原子性操作 encodeIntoResponse(resp, factors); } void encodeIntoResponse(ServletResponse res, BigInteger[] factors) { } BigInteger extractFromRequest(ServletRequest req) { return new BigInteger("7"); } BigInteger[] factor(BigInteger i) { // Doesn't really factor return new BigInteger[] { i }; } }
竞态条件(Race Condition)
在并发编程中,由于不恰当的执行时序而出现的不正确结果是一种非常重要的情况,被称之为竞态条件。 1)当某个计算结果的正确性取决于多线程的交替执行时序是,那么就会出现竞态条件。换句话说,那就是正确的结果取决于运气。 2)竞态条件的本质——基于可能失效的观察结果来做出判断或者执行某个计算。 这类竞态条件被称之为“先检查后执行”。 下面是一种常见情况,延迟初始化。 @NotThreadSafe public class LazyInitRace { private ExpensiveObject instance = null; public ExpensiveObject getInstance() { if (instance == null) instance = new ExpensiveObject(); return instance; } } class ExpensiveObject { }
复合操作
UnsafeCountingFactorizer 和 LazyInitRace 都包含一组需要以原子方式执行(或者说不可分割)的操作。
加锁机制
类似AtomicLong的AtomicRreference来管理因数分解的数值及分解结果? // 这个方法不正确,尽管这些原子引用本身都是现成安全的,但是组合在一起就不是线程安全的了。 //存在lastNumber和lastFactors没有同时更新的情况 @NotThreadSafe public class UnsafeCachingFactorizer extends GenericServlet implements Servlet { private final AtomicReference<BigInteger> lastNumber = new AtomicReference<BigInteger>(); private final AtomicReference<BigInteger[]> lastFactors = new AtomicReference<BigInteger[]>(); public void service(ServletRequest req, ServletResponse resp) { BigInteger i = extractFromRequest(req); if (i.equals(lastNumber.get())) encodeIntoResponse(resp, lastFactors.get()); else { BigInteger[] factors = factor(i); lastNumber.set(i); lastFactors.set(factors); encodeIntoResponse(resp, factors); } } void encodeIntoResponse(ServletResponse resp, BigInteger[] factors) { } BigInteger extractFromRequest(ServletRequest req) { return new BigInteger("7"); } BigInteger[] factor(BigInteger i) { // Doesn't really factor return new BigInteger[]{i}; } } 要保持状态一致性,就需要在单个原子操作中更新所有先关的状态变量。
内置锁
每个java对象都可以用做一个实现同步的锁,这些锁被称之为内置锁(Intrinsic lock)或监视器锁(Monitor Lock)。线程在进入同步代码块(Synchronized Block)之前会自动获得锁,并且在退出同步代码块时自动释放锁,而无论是通过正产的控制路径退出,还是通过从代码块中抛出异常退出。 获得锁的位移方法就是进入由这个锁保护的同步代码快或者方法。
@ThreadSafe public class SynchronizedFactorizer extends GenericServlet implements Servlet { @GuardedBy("this") private BigInteger lastNumber; @GuardedBy("this") private BigInteger[] lastFactors; //同步方法 //并发性能太差,不推荐这么做 public synchronized void service(ServletRequest req, ServletResponse resp) { BigInteger i = extractFromRequest(req); if (i.equals(lastNumber)) encodeIntoResponse(resp, lastFactors); else { BigInteger[] factors = factor(i); lastNumber = i; lastFactors = factors; encodeIntoResponse(resp, factors); } } void encodeIntoResponse(ServletResponse resp, BigInteger[] factors) { } BigInteger extractFromRequest(ServletRequest req) { return new BigInteger("7"); } BigInteger[] factor(BigInteger i) { // Doesn't really factor return new BigInteger[] { i }; } }
重入
如果某个线程试图获得一个已经由他自己持有的锁,那么这个请求就会成功。
“重入”意味着获取锁的操作的粒度是“线程”,而不是“调用”。
用锁来保护状态
注意两点:
1 通常,在简单性与性能之间存在着某种互相制约因素。当实现某个同步策略时,一定不要盲目地为了性能而牺牲简单性。 2 当执行时间较长的计算或者可能无法快速完成的操作时(例如,网络I/O操作或者控制台I/O),一定不要持有锁。
相关推荐
Hy 2020-11-13
xrslt 2020-11-06
yutian0 2020-10-26
杨树 2020-09-21
zhuyonge 2020-08-01
zhuyonge 2020-07-26
xiaoemo0 2020-07-18
fraternityjava 2020-06-26
luohui 2020-06-26
dxyadc 2020-06-26
luohui 2020-06-21
三动 2020-06-21
fengyun 2020-06-14
fraternityjava 2020-06-14
waitui00 2020-06-14
fraternityjava 2020-06-10
shayuchaor 2020-06-07