Skip to content

多线程打印车票

约 958 字大约 3 分钟

java多线程

2025-02-14

上代码(先上的是错误代码,先找错误原因,再上正确代码)

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张票全出来了。只是为了方便观察。