给出一个问题,如下:
解决方案如下:
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中关于线程安全问题的解决详解的详细内容。
   
 
   