技术中心

这里象征着我们的态度和能力

>Java多线程同步问题
作者:中国IT实验室    来源:中国IT实验室    发布时间:2012-01-09      浏览次数:6339
分享到:
欢迎进入Java社区论坛,与200万技术人员互动交流 >>进入
    Java多线程的同步依靠的是对象锁机制,synchronized关键字的背后就是利用了封锁来实现对共享资源的互斥访问。
   
    下面以一个简单的实例来进行对比分析。实例要完成的工作非常简单,就是创建10个线程,每个线程都打印从0到99这100个数字,我们希望线程之间不会出现交叉乱序打印,而是顺序地打印。
   
    先来看第一段代码,这里我们在run()方法中加入了synchronized关键字,希望能对run方法进行互斥访问,但结果并不如我们希望那样,这是因为这里synchronized锁住的是this对象,即当前运行线程对象本身。代码中创建了10个线程,而每个线程都持有this对象的对象锁,这不能实现线程的同步。
   
    代码
   
    package com.vista;
   
    class MyThread implements java.lang.Runnable {
   
    private int threadId;
   
    public MyThread(int id) {
   
    this.threadId = id;
   
    }
   
    @Override
   
    public synchronized void run() {
   
    for (int i = 0; i 《 100; ++i) {
   
    System.out.println("Thread ID: " + this.threadId + " : " + i);
   
    }
   
    }
   
    }
   
    public class ThreadDemo {
   
    /**
   
    * @param args
   
    * @throws InterruptedException
   
    */
   
    public static void main(String[] args) throws InterruptedException {
   
    for (int i = 0; i 《 10; ++i) {
   
    new Thread(new MyThread(i))。start();
   
    Thread.sleep(1);
   
    }
   
    }
   
    }
   
    从上述代码段可以得知,要想实现线程的同步,则这些线程必须去竞争一个唯一的共享的对象锁。
   
    基于这种思想,我们将第一段代码修改如下所示,在创建启动线程之前,先创建一个线程之间竞争使用的Object对象,然后将这个Object对象的引用传递给每一个线程对象的lock成员变量。这样一来,每个线程的lock成员都指向同一个Object对象。我们在run方法中,对lock对象使用synchronzied块进行局部封锁,这样就可以让线程去竞争这个唯一的共享的对象锁,从而实现同步。
   
    代码
   
    package com.vista;
   
    class MyThread implements java.lang.Runnable {
   
    private int threadId;
   
    private Object lock;
   
    public MyThread(int id, Object obj) {
   
    this.threadId = id;
   
    this.lock = obj;
   
    }
   
    @Override
   
    public void run() {
   
    synchronized (lock) {
   
    for (int i = 0; i 《 100; ++i) {
   
    System.out.println("Thread ID: " + this.threadId + " : " + i);
   
    }
   
    }
   
    }
   
    }
   
    public class ThreadDemo {
   
    /**
   
    * @param args
   
    * @throws InterruptedException
   
    */
   
    public static void main(String[] args) throws InterruptedException {
   
    Object obj = new Object();
   
    for (int i = 0; i 《 10; ++i) {
   
    new Thread(new MyThread(i, obj))。start();

[1] [2] 下一页

4000-880-989
(24小时热线)
联系客服
微信公众号

官方公众号

小程序

©2008-2022 CORPORATION ALL Rights Reserved. 香港精准正版资料版权所有 滇ICP备09003328号-1 滇公网安备 53011102000818号 增值电信业务经营许可证号:滇B2-20110045
昆明那家网络公司好,新媒体运营,网站优化,网络推广,网站建设,网页设计,网站设计,网站推广,云南网站公司,昆明新媒体公司,云南网红主播,昆明SEO公司,昆明网站建设,昆明网络推广,昆明网站优化,昆明网站推广,红河网站建设,大理网络公司,曲靖网络公司,丽江网站设计,昭通网络公司,保山大数据服务,智慧高速建设,智慧校园服务,云南IDC服务商,网络安全测评,等保测评,网站关键词排名优化服务,服务客户尽超2000余家,一切尽在香港精准正版资料,服务电话:13888956730