这篇文章给大家介绍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项目中的线程安全问题如何解决就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。