Java中关于线程安全问题的解决详解

给出一个问题,如下:

解决方案如下:

public class Demo_5 {    public static void main(String[] args) {        //创建一个窗口        TicketWindow tw1=new TicketWindow();        //使用三个线程同时启动        Thread t1=new Thread(tw1);        Thread t2=new Thread(tw1);        Thread t3=new Thread(tw1);                t1.start();        t2.start();        t3.start();    }}//售票窗口类class TicketWindow implements Runnable{    private int nums=2000;                         //一共2000张票    @Override    public void run() {        while(true){                                if(nums>0){                        //先判断是否还有票                    //Thread.currentThread().getName()得到当前线程的名字                    System.out.println(Thread.currentThread().getName()+"在售出第"+nums+"张票");    //显示售票信息                                    //出票的速度是一秒出一张                    try {                        Thread.sleep(1000);                    } catch (InterruptedException e) {                        e.printStackTrace();                    }                                    nums--;                }else{                    break;                            //售票结束                }                      }          }    }

执行这段代码发现问题,就是同一张票号可能被多个售票窗口出售,惹祸的代码就是if else语句块。

解决方法就是在需要同步的代码段用synchronized(Object){你要同步的代码}即可。

修改后代码如下:

public class Demo_5 {    public static void main(String[] args) {        //创建一个窗口        TicketWindow tw1=new TicketWindow();        //使用三个线程同时启动        Thread t1=new Thread(tw1);        Thread t2=new Thread(tw1);        Thread t3=new Thread(tw1);                t1.start();        t2.start();        t3.start();    }}//售票窗口类class TicketWindow implements Runnable{    private int nums=2000;                         //一共2000张票    @Override    public void run() {        while(true){                    //认为if else这段代码要保证其原子性(同步代码块)            synchronized (this) {                        if(nums>0){                             //先判断是否还有票                    //Thread.currentThread().getName()得到当前线程的名字                    System.out.println(Thread.currentThread().getName()+"在售出第"+nums+"张票");    //显示售票信息                                    //出票的速度是一秒出一张                    try {                        Thread.sleep(1000);                    } catch (InterruptedException e) {                        e.printStackTrace();                    }                                    nums--;                }else{                    break;                            //售票结束                }                            }        }    }    }

执行这段代码发现出票正常了。

线程1正执行需要做同步处理的代码,线程2,3,4……blocked,被放入了线程等待池,就好像某人上厕所前先把门关上(上锁),完事之后再出来(解锁),然后别人就可以继续使用了。

以上就是Java中关于线程安全问题的解决详解的详细内容,更多请关注其它相关文章!

在你成功地把自己推销给别人之前,你必须百

Java中关于线程安全问题的解决详解

相关文章:

你感兴趣的文章:

标签云: