使用Runnable实现数据共享
程序员文章站
2023-12-22 22:18:46
使用runnable实现数据共享,供大家参考,具体内容如下
先上代码:
public class testthread {
private static...
使用runnable实现数据共享,供大家参考,具体内容如下
先上代码:
public class testthread { private static final logger logger = loggerfactory.getlogger(testthread.class); private final class myrunnable implements runnable { private int i; public myrunnable() { this.i = 10; } public void run() { while(i > 0) { synchronized (this) { if (i > 0) { i--; logger.debug("{} buy one ticket, {} left. ", thread.currentthread().getname(), i); } } } } } @test public void testrunable() throws interruptedexception{ myrunnable myrunnable = new myrunnable(); thread th1 = new thread(myrunnable); thread th2 = new thread(myrunnable); th1.start(); th2.start(); th1.join(); th2.join(); } }
楼上的代码很简单,模拟一个售票系统。通过两个thread对象开启两条线程同时运行一个myrunnable实例。
几个注意点:
1. 没有加上synchronised关键词的话,即
public void run() { while(i > 0) { if (i > 0) { i--; logger.debug("{} buy one ticket, {} left. ", thread.currentthread().getname(), i); } } }
系统的运行结果:
thread-1 buy one ticket, 8 left. thread-2 buy one ticket, 8 left. thread-2 buy one ticket, 6 left. thread-1 buy one ticket, 6 left. thread-2 buy one ticket, 5 left. thread-1 buy one ticket, 4 left. thread-2 buy one ticket, 3 left. thread-1 buy one ticket, 2 left. thread-2 buy one ticket, 1 left. thread-1 buy one ticket, 0 left.
可以看到,缺少同步的程序输出明显有问题。
2. 在进入同步代码块之后,还需要对i的值再进行一次判断,即,如果不加if判断:
public void run() { while(i > 0) { synchronized (this) { i--; logger.debug("{} buy one ticket, {} left. ", thread.currentthread().getname(), i); } } }
程序的运行结果为:
thread-2 buy one ticket, 9 left. thread-2 buy one ticket, 8 left. thread-2 buy one ticket, 7 left. thread-2 buy one ticket, 6 left. thread-2 buy one ticket, 5 left. thread-2 buy one ticket, 4 left. thread-2 buy one ticket, 3 left. thread-2 buy one ticket, 2 left. thread-2 buy one ticket, 1 left. thread-2 buy one ticket, 0 left. thread-1 buy one ticket, -1 left.
可以看出,出现了“多卖”的现象, 所以需要在进入同步代码块中再进行一次if判断。
总结
synchronised用于互斥访问共享变量, 并在同步代码块中使用if判断更新共享变量。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
推荐阅读
-
使用Runnable实现数据共享
-
java实现Runnable接口适合资源的共享
-
H5中怎样使用postMessage实现两个网页间传递数据
-
在没有服务器的网页之间如何实现数据的共享_html/css_WEB-ITnose
-
php使用curl通过代理获取数据的实现方法
-
织梦使用{dede:listsql}标签调用数据并实现静态分页
-
解析使用C# lock同时访问共享数据
-
通过代理类实现java连接数据库(使用dao层操作数据)实例分享
-
vue 使用 async 和 await 实现异步 axios 同步化(实战案例:数据异步校验通过后,再执行保存)
-
使用phpexcel类实现excel导入mysql数据库功能(实例代码)