Java 多线程卖票例子

89 阅读 0 评论 59 点赞

我是靠谱客的博主土豪宝马，这篇文章主要介绍Java 多线程卖票例子，现在分享给大家，希望可以做个参考。

以卖票的例子来介绍多线程和资源共享。

　　卖票是包含一系列动作的过程，有各种操作，例如查询票、收钱、数钱、出票等，其中有一个操作是每次卖掉一张，就将总的票数减去1。有10张票，如果一个人卖票，先做查票、收钱、数钱等各种操作，再将总的票数减去1，效率很低。如果多个人卖票，每个人都是做同样的操作，数钱、检查钱，最后将总的票数减1，这样效率高。但是有一个问题，如果出现两个人同时将总的票数减掉了1，例如，A、B两个人同时读取到票的总数是10，A从中减去1，同时B也从中减去1，总数显示是9，其实票只有8张。导致数据错误。

　　按照正常逻辑，同一时刻只允许一个人来从总票数中减去1，A读取总票数，再减去1的过程中，B必须等待，等A操作完了，B才能进行。其实票就是共享资源，一次只能由一个人访问。这里就要用到同步机制，即锁机制，使用关键词synchronized将读取总的票数，并减去1的操作锁定，使得一次只能由一个人访问。每个售票员就是一个线程，多个售票员进行同一项卖票任务。

　　synchronized原理是，执行synchronized部分代码的时候必须需要对象锁，而一个对象只有一个锁，只有执行完synchronized里面的代码后释放锁，其他线程才可以获得锁，那么就保证了同一时刻只有一个线程访问synchronized里面的代码。使得资源共享的关键是，只有一个实例，synchronized使用的是同一把锁，用实例的锁或者定义一个实例。这就需要使用实现Runnable接口的方式，实现多线程，这样传入的是一个实例。继承Thread的方式，传入的是多个实例，每个实例都有一个锁，那就无法实现控制。

复制代码

package com.itmayiedu;

/**
 * 
 * @classDesc: 功能描述:(多线程之买火车票案例-使用同步代码块例子)
 * @author: 余胜军
 * @createTime: 2017年8月14日 下午9:56:00
 * @version: v1.0
 * @copyright:上海每特教育科技有限公司
 */
class ThreadTrain implements Runnable {
	// 这是货票总票数,多个线程会同时共享资源
	private int trainCount = 100;
	// 自定义多线程同步锁
	private Object oj = new Object();

@Override
	public void run() {
		while (trainCount > 0) {// 循环是指线程不停的去卖票
			sale();
			try {
				// 等待100毫秒
				Thread.sleep(100);
			} catch (InterruptedException e) {

}

}
	}

/**
	 * 
	 * @methodDesc: 功能描述:(出售火车票)
	 * @author: 余胜军
	 * @param:
	 * @createTime:2017年8月9日 下午9:49:11
	 * @returnType: void
	 * @copyright:上海每特教育科技有限公司
	 */
	public void sale() {
		synchronized (oj) {
			if (trainCount > 0) {   
				System.out.println(Thread.currentThread().getName() + ",出售 第" + (100 - trainCount + 1) + "张票.");
				trainCount--;
				try {
					Thread.sleep(10);
				} catch (Exception e) {

}
			}
		}
	}
}

public class ThreadDemo {

public static void main(String[] args) {
	
		ThreadTrain threadTrain = new ThreadTrain(); //定义 一个实例
		Thread thread1 = new Thread(threadTrain, "一号窗口");
		Thread thread2 = new Thread(threadTrain, "二号窗口");
		thread1.start();
		thread2.start();
	}

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package com.itmayiedu;

/**
 * 
 * @classDesc: 功能描述:(多线程之买火车票案例-使用同步代码块例子)
 * @author: 余胜军
 * @createTime: 2017年8月14日 下午9:56:00
 * @version: v1.0
 * @copyright:上海每特教育科技有限公司
 */
class ThreadTrain implements Runnable {
	// 这是货票总票数,多个线程会同时共享资源
	private int trainCount = 100;
	// 自定义多线程同步锁
	private Object oj = new Object();

	@Override
	public void run() {
		while (trainCount > 0) {// 循环是指线程不停的去卖票
			sale();
			try {
				// 等待100毫秒
				Thread.sleep(100);
			} catch (InterruptedException e) {

			}

		}
	}

	/**
	 * 
	 * @methodDesc: 功能描述:(出售火车票)
	 * @author: 余胜军
	 * @param:
	 * @createTime:2017年8月9日 下午9:49:11
	 * @returnType: void
	 * @copyright:上海每特教育科技有限公司
	 */
	public void sale() {
		synchronized (oj) {
			if (trainCount > 0) {   
				System.out.println(Thread.currentThread().getName() + ",出售 第" + (100 - trainCount + 1) + "张票.");
				trainCount--;
				try {
					Thread.sleep(10);
				} catch (Exception e) {

				}
			}
		}
	}
}

public class ThreadDemo {

	public static void main(String[] args) {
	
		ThreadTrain threadTrain = new ThreadTrain(); //定义 一个实例
		Thread thread1 = new Thread(threadTrain, "一号窗口");
		Thread thread2 = new Thread(threadTrain, "二号窗口");
		thread1.start();
		thread2.start();
	}

}