图片来源：https://blog.csdn.net/luoweifu/article/details/46673975
上代码（先上的是错误代码，先找错误原因，再上正确代码）
package test;
public class ThreadSyn implements Runnable{
private Integer sum;//票总数
private Integer current = 1;//当前出售票(初始值为1)
public ThreadSyn(Integer sum) {
this.sum = sum;
}
@Override
public void run() {
while(sum-current >= 0) {
System.out.print(Thread.currentThread().getName() + "出售第" + current + "张票。");
if(current <= sum) {
System.out.println("售票成功！还剩" + (sum-current) + "张票。");
current++;
} else {
System.out.println("售票失败！该票已售完。");
}
}
}
}
package test;
public class ThreadTest {
public static void main(String args[]) {
ThreadSyn threadSyn = new ThreadSyn(5);
Thread threads[] = new Thread[3];
for(int i=0;i<threads.length;i++) {
threads[i] = new Thread(threadSyn, "第" + (i+1) + "个窗口");
threads[i].start();
}
}
}
错误代码在运行之前，看着逻辑是没问题了。运行结果：
第3个窗口出售第1张票。第1个窗口出售第1张票。售票成功！还剩4张票。
第2个窗口出售第1张票。第1个窗口出售第2张票。售票成功！还剩4张票。
售票成功！还剩3张票。
售票成功！还剩3张票。
第1个窗口出售第4张票。第3个窗口出售第3张票。售票成功！还剩0张票。
第2个窗口出售第5张票。售票成功！还剩0张票。
售票失败！该票已售完。
显然不对。原因就是多个线程同时进了run方法。那就限制成单个线程。
再上代码：(正确代码)
package test;
public class ThreadSyn implements Runnable{
private Integer sum;//票总数
private Integer current = 1;//当前出售票(初始值为1)
public ThreadSyn(Integer sum) {
this.sum = sum;
}
@Override
public void run() {
while(sum-current >= 0) {
synchronized (this) {
System.out.print(Thread.currentThread().getName() + "出售第" + current + "张票。");
if(current <= sum) {
System.out.println("售票成功！还剩" + (sum-current) + "张票。");
try {
Thread.sleep(100);
current++;
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
System.out.println("售票失败！该票已售完。");
}
}
}
}
}
package test;
public class ThreadTest {
public static void main(String args[]) {
ThreadSyn threadSyn = new ThreadSyn(500);
Thread threads[] = new Thread[8];
for(int i=0;i<threads.length;i++) {
threads[i] = new Thread(threadSyn, "第" + (i+1) + "个窗口");
threads[i].start();
}
}
}
输出结果：（内容太多，中间就用......代替了）
第1个窗口出售第1张票。售票成功！还剩499张票。
第1个窗口出售第2张票。售票成功！还剩498张票。
第1个窗口出售第3张票。售票成功！还剩497张票。
第8个窗口出售第4张票。售票成功！还剩496张票。
第8个窗口出售第5张票。售票成功！还剩495张票。
......
第3个窗口出售第495张票。售票成功！还剩5张票。
第3个窗口出售第496张票。售票成功！还剩4张票。
第3个窗口出售第497张票。售票成功！还剩3张票。
第4个窗口出售第498张票。售票成功！还剩2张票。
第4个窗口出售第499张票。售票成功！还剩1张票。
第4个窗口出售第500张票。售票成功！还剩0张票。
第5个窗口出售第501张票。售票失败！该票已售完。
第6个窗口出售第501张票。售票失败！该票已售完。
第7个窗口出售第501张票。售票失败！该票已售完。
第8个窗口出售第501张票。售票失败！该票已售完。
第1个窗口出售第501张票。售票失败！该票已售完。
第3个窗口出售第501张票。售票失败！该票已售完。
第2个窗口出售第501张票。售票失败！该票已售完。
正确代码比错误代码多了两个内容。
一个是 synchronized (this) {} 同步锁，是解决错误代码问题的地方。
一个是 Thread.sleep(100); 这个就是使当前线程暂时0.1秒，这样肉眼才能看到刷刷刷的在售票，不然刷一下500张票全出来了。只是为了方便观察。
