谈谈并发编程中的线程安全性

1. 线程安全性

在单线程程序中,我们并不需要去考虑线程的安全性。但是在多线程程序中,由于多个线程要共享相同的内存地址空间,并且是并发运行,因此它们可能会访问或修改其他线程正在使用的变量。

所以,在这种情况下,可能会引发不正确的结果,在并发编程中,称之为“竞态条件”。

在并发编程中,这种由于不恰当的执行时序而引发不正确的结果情况叫做竞态条件。

​ —— Java并发编程实战

2. 示例

例如,我们想在Servlet中统计客户端的请求个数。这一点都不难,不就是在客户端每次请求时将count值自加1嘛:

@WebServlet(name = "SafeFactorizer", urlPatterns = "/*", loadOnStartup = 1)
public class SafeFactorizer extends HttpServlet {
    
    private long count = 0;
    
    @Override
    protected void service(HttpServletRequest req, HttpServletResponse resp) {
        ++count;
        System.out.println("Now count is " + count);
        
        // 模拟耗时的IO操作
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }
    
}

但是,++count看似是一个紧凑的单个操作,其实它包含了三个独立的操作:

  • 读取value
  • value的值加1
  • 将计算的结果写入value

可以看到,这并不是一个原子操作(不可分,连续完成的)。如果客户端的请求达到一定数目,很有可能统计到不正确的数值。我们可以模拟999个客户端请求一下,这里使用Python多线程模拟了999个请求,并打印出所有请求花费的总时间t2-t1

def fun():
    requests.get('http://localhost:8080')
    
if __name__ == '__main__':
    threads = []       # 存放已经创建线程实例的列表
    for i in range(1, 1000):
        t = threading.Thread(target=fun)
        threads.append(t)
        
    t1 = time.time()   # 请求开始时间
    for t in threads:
        t.setDaemon(True)
        t.start() 
    t.join() 
    
    t2 = time.time()   # 请求结束时间
    print("Total time is {}".format(t2 - t1))

可以看到服务端中最后打印出的count值为989,和预期的客户端999个请求的结果不相同。说明由于竞态条件的问题,导致统计出现了错误的结果(预期应该统计出999):

TIM截图20181024221940.png

而且在客户端的控制台上,也得到全部请求花费的总时间:

Total time is 2.623112201690674  # 客户端打印结果

你可能要问了,这还不简单吗?Java有内置锁,我们给service方法加上一个synchronized关键字实现同步不就可以解决了吗。当然可以,我们可以试试:

 @Override
 protected synchronized oid service(HttpServletRequest req, HttpServletResponse resp) {
    ...
 }

这时候,我们来尝试模拟使用999客户端来请求,可以看到结果的确符合了我们的期望:

TIM截图20181024223118.png

但是客户端花费的时间和没使用同步前相差的不是一丁半点:

Total time is 191.81470131874084

这种同步机制确实使得确保service方法的线程安全性,但是在这种情况下:同一时刻只能有一个线程可以执行service方法,这样就背离了Servlet框架同时处理多个请求的初衷。幸运的是,我们可以通过缩小同步代码块的作用范围,可以很容易地做到既确保Servlet的并发性,同时又维护线程的安全性

@Override
 protected void service(HttpServletRequest req, HttpServletResponse resp) {
    synchronized (this) {
        ++count;
    }
     try {
         Thread.sleep(200);
     } catch (InterruptedException e) {
         e.printStackTrace();
    }
 }

现在,我们看下客户端的全部请求花费的时间。可以看到,和没有使用同步加锁机制所花费的时间大致一样:

Total time is 2.9431087970733643

3. 总结

除了像上面那种读写——修改——写入操作,还有例如单例模式的懒汉式实现方式:

public class LazyInitRace {

    private ExpensiveObject instance = null;
    
    private LazyInitRace() {}

    public ExpensiveObject getInstance() {
        if (instance == null) {
            return new ExpensiveObject();
        }
        return instance;
    }
}

可以看到,我们在getInstance方法中, 做了“先检查后执行”的操作。在并发编程中,把这些操作称之为复合操作:包含了一组必须以原子方式执行的操作以确保线程的安全性。

我们考虑一种情况:当线程A执行了getInstance方法, 检查到instance为空,因而创建了新的ExpensiveObject对象;此时,线程B也执行了getInstance方法,但是此时线程检查出的instance是否为空,取决于不可预测的时序(线程调度方式、A创建对象花费时间),如果线程B也检查到instance为空。那么在这两次调用getInstance方法将会得到不同的结果,而不是单一的实例对象了。

解决的方式也非常容易,只需要让getInstance方法实现同步即可:

public synchronized ExpensiveObject getInstance() {
    if (instance == null) {
        return new ExpensiveObject();
    }
    return instance;
}

因此,在并发编程中, 我们应该确保操作的原子性。如果某些复合操作不具备原子性,我们则可以使用synchronized加锁同步机制来实现某些复合操作的原子性。

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

推荐阅读更多精彩内容