线程同步

1、synchronized

单例模式下synchronized实现同步

public class Single {
    
    private Single() {}

    private static Single instance;

    public static Single getInstance() {

        if (instance == null) {
            synchronized (Single.class) {
                if (instance == null) {
                    instance = new Single();
                }
            }
        }
        return instance;
    }
}

2、lock

单例模式下lock实现同步

public class Single {

    private Single() {}

    private static Single instance;

    private static final ReentrantLock lock = new ReentrantLock();

    public static Single getInstance() {

        if (instance == null) {
            lock.lock();
            if (instance == null) {
                instance = new Single();
            }
            lock.unlock();

        }
        return instance;
    }

}

3、condition

指定条件来唤醒线程

public class Demo {

    private int signal;
    Lock lock = new ReentrantLock();
    Condition a = lock.newCondition();
    Condition b = lock.newCondition();
    Condition c = lock.newCondition();
    public void a() {
        lock.lock();
        while(signal != 0 ) {
            try {
                a.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("a");
        signal ++;
        b.signal();
        lock.unlock();
    }

    public  void b() {
        lock.lock();
        while(signal != 1) {
            try {
                b.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("b");
        signal ++;
        c.signal();
        lock.unlock();
    }

    public  void c () {
        lock.lock();
        while(signal != 2) {
            try {
                c.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("c");
        signal = 0;
        a.signal();
        lock.unlock();
    }

    public static void main(String[] args) {
        Demo d = new Demo();
        A a = new A(d);
        B b = new B(d);
        C c = new C(d);
        new Thread(a).start();
        new Thread(b).start();
        new Thread(c).start();
    }
}

class A implements Runnable {

    private Demo demo;
    public A(Demo demo) {
        this.demo = demo;
    }
    @Override
    public void run() {
        while(true) {
            demo.a();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}
class B implements Runnable {

    private Demo demo;
    public B(Demo demo) {
        this.demo = demo;
    }

    @Override
    public void run() {
        while(true) {
            demo.b();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
class C implements Runnable {

    private Demo demo;
    public C(Demo demo) {
        this.demo = demo;
    }
    @Override
    public void run() {
        while(true) {
            demo.c();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 多线程三个特征:原子性、可见性以及有序性. 同步锁 /并发锁/ 读写锁,显示锁, ReentrantLock与Co...
    架构师springboot阅读 1,971评论 0 5
  • 线程安全 当多个线程访问一个对象时,如果不用考虑这些线程在运行时环境下的调度和交替执行,也不需要进行额外的同步,或...
    闽越布衣阅读 783评论 0 6
  • 引用自多线程编程指南应用程序里面多个线程的存在引发了多个执行线程安全访问资源的潜在问题。两个线程同时修改同一资源有...
    Mitchell阅读 2,022评论 1 7
  • 多个线程同时使用共享对象,这种情形被称为竞争条件(Race Condition),竞争条件是多线程环境中非常常见的...
    LH_晴阅读 3,483评论 0 2
  • 理解同步 在应用程序中,当多个线程需要对同一个资源进行读写操作时,可能会引起冲突。为了解决这个问题,就需要保证这个...
    官先生Y阅读 263评论 0 1