Java线程安全 |
您所在的位置：网站首页 › 同步代码块的锁 › Java线程安全 |
Java线程安全
|
当不使用代码锁的时候是不能够保证线程的安全性问题的，不使用安全锁的时候有时候可能会出现很多问题，例如常见的问题有： 次序的扰乱： 我们经常会看到卖票等程序买的票数的张数不是紧挨着卖的，而是多个线程可能买的票的序号相同，而且可能循环已经截止了但还是会输出多余的语句，这是因为循环结束前线程已经抢夺到了cup的执行权但是没有执行出来，所以当循环结束后仍会继续打印出来多余的语句。有时候还会出现卖的票是负值的情况，这都是由于没有使用同步锁的原因 注意： 1、至少有两个线程或以上而且共享同一个资源而且操作资源的语句至少有两条 才会有线程安全问题的出现(使用同步锁) 2、有多个同步锁的时候，参数可以是随便一个对象,但是必须是同一个对象同一个锁（就是多个同步锁中的参数是一个对象才行）🔒 3、对于持有锁 ，线程睡觉不会释放锁（下面代码块中的注释中有标注持有锁） 说明： 1、对于同步锁，当一个线程进入同步锁内后，其他的线程就不能再次进入同步锁中，只有等该线程执行完同步锁中的代码之后，才会有下一个线程进入同步锁 2、对于刚从同步锁中出来的线程，仍会进入新一轮进入同步锁的线程抢夺当中 同步锁——同步代码块： package thread; //至少有两个线程或以上而且共享同一个资源而且操作资源的语句至少有两条 才会有线程安全(使用同步锁) //不要同时执行run()方法 public class _a2_线程安全 { public static void main(String[] args) { MyRun2 mr = new MyRun2(); //创建线程对象(每一个线程共用同一个对象) Thread t1 = new Thread(mr,"1号窗口"); Thread t2 = new Thread(mr,"2号窗口"); Thread t3 = new Thread(mr,"3号窗口"); Thread t4 = new Thread(mr,"4号窗口"); //启动 t1.start(); t2.start(); t3.start(); t4.start(); } } class MyRun2 implements Runnable{ private int ticket = 100; // Object obj = new Object(); @Override public void run() { // TODO Auto-generated method stub while(true) { //-----------------------同步代码块 //this有1和0两个值 synchronized (/*obj*/this) {//同步锁(参数需要是随便一个对象,但是必须是同一个对象同一个锁🔒) if(ticket>0) { try { Thread.sleep(10);//持有锁 线程睡觉不会释放锁 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+"售出"+ticket +"号票🎫"); ticket--; }else break; } } } } 同步锁——同步函数/同步方法： package thread; //至少有两个线程以上而且共享同一个资源 才会有线程安全(使用同步锁) //不要同时执行run()方法 public class _a3_线程安全2 { public static void main(String[] args) { MyRun3 mr = new MyRun3(); //创建线程对象(每一个线程共用同一个对象) Thread t1 = new Thread(mr,"1号窗口"); Thread t2 = new Thread(mr,"2号窗口"); Thread t3 = new Thread(mr,"3号窗口"); Thread t4 = new Thread(mr,"4号窗口"); //启动 t1.start(); t2.start(); t3.start(); t4.start(); } } class MyRun3 implements Runnable{ private int ticket = 100; // Object obj = new Object(); @Override public void run() { // TODO Auto-generated method stub while(true) { saleTicket(); if(ticket0) { try { Thread.sleep(10);//持有锁 线程睡觉不会释放锁 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+"售出"+ticket +"号票🎫"); ticket--; } } }
|
【本文地址】
今日新闻 |
推荐新闻 |