使用Runnable实现数据共享
使用Runnable实现数据共享，供大家参考，具体内容如下
先上代码：
publicclassTestThread{
privatestaticfinalLoggerlogger=LoggerFactory.getLogger(TestThread.class);
privatefinalclassMyRunnableimplementsRunnable{
privateinti;
publicMyRunnable(){
this.i=10;
}
publicvoidrun(){
while(i>0){
synchronized(this){
if(i>0){
i--;
logger.debug("{}buyoneticket,{}left.",Thread.currentThread().getName(),i);
}
}
}
}
}
@Test
publicvoidtestRunable()throwsInterruptedException{
MyRunnablemyRunnable=newMyRunnable();
Threadth1=newThread(myRunnable);
Threadth2=newThread(myRunnable);
th1.start();
th2.start();
th1.join();
th2.join();
}
}
楼上的代码很简单，模拟一个售票系统。通过两个Thread对象开启两条线程同时运行一个MyRunnable实例。
几个注意点：
1.没有加上synchronised关键词的话，即
publicvoidrun(){
while(i>0){
if(i>0){
i--;
logger.debug("{}buyoneticket,{}left.",Thread.currentThread().getName(),i);
}
}
}
系统的运行结果：
Thread-1buyoneticket,8left. Thread-2buyoneticket,8left. Thread-2buyoneticket,6left. Thread-1buyoneticket,6left. Thread-2buyoneticket,5left. Thread-1buyoneticket,4left. Thread-2buyoneticket,3left. Thread-1buyoneticket,2left. Thread-2buyoneticket,1left. Thread-1buyoneticket,0left.
可以看到，缺少同步的程序输出明显有问题。
2.在进入同步代码块之后，还需要对i的值再进行一次判断，即，如果不加if判断：
publicvoidrun(){
while(i>0){
synchronized(this){
i--;
logger.debug("{}buyoneticket,{}left.",Thread.currentThread().getName(),i);
}
}
}
程序的运行结果为：
Thread-2buyoneticket,9left. Thread-2buyoneticket,8left. Thread-2buyoneticket,7left. Thread-2buyoneticket,6left. Thread-2buyoneticket,5left. Thread-2buyoneticket,4left. Thread-2buyoneticket,3left. Thread-2buyoneticket,2left. Thread-2buyoneticket,1left. Thread-2buyoneticket,0left. Thread-1buyoneticket,-1left.
可以看出，出现了“多卖”的现象，所以需要在进入同步代码块中再进行一次if判断。
总结
synchronised用于互斥访问共享变量，并在同步代码块中使用if判断更新共享变量。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。