多线程安全性:每个人都在谈,但是不是每个人都谈地清

要编写多线程安全的代码,最关键的一点就是需要对于共享的可变的状态进行访问控制:

  • 所谓共享的,指的是该变量可能同时被多个线程访问;
  • 所谓可变的,指的是该变量在生命周期内其值可能放生变化。

如果在多线程同时访问一个共享可变的状态变量,但是没有进行有效的访问控制的话,那么程序的运行就可能带来意料之外的错误。为了解决这个问题,有以下三种办法:

  1. 不在线程中共享该状态变量(很可惜,不可能完全避免,但是能尽量减少不必要的共享)。
  2. 共享的变量设置为不可变状态(简单而有效,不可变的对象天然就是多线程安全的,比如String和BigInteger)。
  3. 访问状态变量时使用同步机制(这是并发编程的重点)。

大部分情况下,讨论的多线程安全都是关于访问共享可变的状态变量,因此都不得不涉及到数据同步机制,但是在具体讨论数据同步的访问控制之前,我们需要先讨论一个问题,什么是多线程安全?

1. 多线程安全性

多线程安全性的定义可能众说纷纭,但是其最核心的一点就是正确性,也就是程序的行为结果和预期一致。

当多个线程访问某个类时,不管运行环境采用何种线程调度算法或者这些线程如何交替执行,且不需要在主程序中添加任何额外的协同机制,这个类都能表现出正确的行为,那么这个类就是线程安全的。——《Java Concurrency in Practice》

这里需要额外注意下,一般都是把必要的同步机制封装在类中,让使用该类的客户端无需考虑多线程的问题。

当然也不一定需要同步机制才能保持多线程安全,比如一个类是无状态的:

public class StatelessFactorizer extends GenericServlet implements Servlet {

    public void service(ServletRequest req, ServletResponse resp) {
        BigInteger i = extractFromRequest(req);
        BigInteger[] factors = factor(i);
        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 };
    }
}

这是一个最简单的网络服务,提供因式分解的功能。该服务是状态无关的,即使再多的请求同时处理,也不会相互影响。

2. 原子性

如何确保多线程安全呢?简单说就是让对于共享可变的状态变量的访问操作都是原子性的,也就是不可分隔的。

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);
        //Not Thread-Safe
        ++count;
        encodeIntoResponse(resp, factors);
    }
    ......
}

稍有多线程编程经验的人,都是知道上面的代码不是多线程安全的。当使用count变量来记录服务被调用的次数时,该类就变成有状态的了。但是自增长++操作不是原子性的,其可以分解为读取数值,增加数值和回写数值,其中每一步都是可以被打断和暂停的,多线程访问count变量是就可能会造成问题。这是一种由于不恰当的执行顺序而造成的多线程错误,被称为竞态条件

竞态条件多是由于“先检查后执行”,也就是先去检查一个值的状态,根据这个状态再去执行响应的动作。但是在多线程中,读取这个值的状态后,该值就可能被其他线程修改了,因而失效。

要解决以上问题,就需要将一组操作组成一个原子性的复合操作。在复合操作没有执行完之前,该操作过程不能被打断。

public class CountingFactorizer extends GenericServlet implements Servlet {
    private final AtomicLong count = new AtomicLong(0);

    public long getCount() { return count.get(); }

    public void service(ServletRequest req, ServletResponse resp) {
        BigInteger i = extractFromRequest(req);
        BigInteger[] factors = factor(i);
        //Thread-Safe
        count.incrementAndGet();
        encodeIntoResponse(resp, factors);
    }
}

比如上面的代码使用原子类AtomicLongincrementAndGet方法保证自增长是原子性的。

3. 加锁机制

如果多线程中的共享状态变量有多个,该如何处理呢?只靠每个变量为原子类型是不够的,还需要把所有状态变量之间的操作都设置成原子性的才行。

多线程安全要求在一个原子性操作中更新所有相关状态的变量。

这样的要求在Java中可以使用内置锁和同步代码块来实现。

synchronized (lock){
     // doing someting;
}

每个对象内部都会有一个内置锁,当进入同步代码块时,对象的内置锁就会被自动获得,在退出同步代码块(包括抛出异常)都会自动释放内置锁。同步代码块中的程序,将会保证是原子性的,这是因为内置锁是一种互斥锁,每次只能有一个线程获得该锁,从而保证多线程之间相互不干扰。

需要说明的是,内置锁提供重入机制,也就是说如果当前线程已经获得某个对象的内置锁,当它再去请求该锁时也会成功,这就代表着内置锁的操作粒度是线程,而不是调用。

内置锁的重入机制设计有着良苦用心,尤其是在继承父类代码中同步操作时,比如:

public class A{
    public synchronized void function(){
    }
}

public class B extends A{
    public synchronized void funtcion(){
        super.function();
        ......
    }
}

如果没有重入机制,当B类中的function已经获得内置锁之后,再去调用父类中同步方法function,就会因内置锁未获得而等待,但是外部的子类的方法因内部父类的方法被拥塞也一直都不能释放内置锁,故而产生死锁。

4. 用内置锁来保护状态

锁的出现,让并行执行的代码路径出现了必要的串行。不过需要注意的是,如果使用锁来控制某个变量的访问,对于该变量的所有访问位置上都需要加入锁。

每个共享可变的变量,都应该只有一个锁来保护。如果由多个变量协同完成操作,则这些变量应该由同一个锁来保护。

在设置同步代码块时,应该避免同步控制的滥用。最极端的例子就是全部代码都在同步代码块中,这样虽然是多线程安全的,但是会造成所有线程变为串行,丧失了并发的意义。

为了提高性能,我们应该尽可能缩小同步代码块的范围,只在需要的情况下使用。比如这样:

public class CachedFactorizer extends GenericServlet implements Servlet {
    @GuardedBy("this") private BigInteger lastNumber;
    @GuardedBy("this") private BigInteger[] lastFactors;
    @GuardedBy("this") private long hits;
    @GuardedBy("this") private long cacheHits;

    public synchronized long getHits() {
        return hits;
    }

    public synchronized double getCacheHitRatio() {
        return (double) cacheHits / (double) hits;
    }

    public void service(ServletRequest req, ServletResponse resp) {
        BigInteger i = extractFromRequest(req);
        BigInteger[] factors = null;
        synchronized (this) {
            ++hits;
            if (i.equals(lastNumber)) {
                ++cacheHits;
                factors = lastFactors.clone();
            }
        }
        if (factors == null) {
            factors = factor(i);
            synchronized (this) {
                lastNumber = i;
                lastFactors = factors.clone();
            }
        }
        encodeIntoResponse(resp, factors);
    }

    void encodeIntoResponse(ServletResponse resp, BigInteger[] factors) {
    }
}

如何选取合适的同步代码块范围,需要基于实际需求,在简单性和并发性之间平衡。

在同一个代码块中最好只使用一种同步机制,这样便于维护。另外,不要在同步代码块中进行耗时操作,这样对于性能是很大的消耗。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,132评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,802评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,566评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,858评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,867评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,695评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,064评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,705评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,915评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,677评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,796评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,432评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,041评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,992评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,223评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,185评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,535评论 2 343

推荐阅读更多精彩内容