黑马程序员技术交流社区

标题: 模拟火车站程序，调试过程中出现，错误异常。大神进来..... [打印本页]

作者: nine789 时间: 2015-6-25 20:44
标题: 模拟火车站程序，调试过程中出现，错误异常。大神进来.....
今天把昨天的代码补全了，但是总是会出现一些异常，出现的的错误是，错误的行数不确定，请大神帮忙解答一下，昨天帖子地址：[url]http://bbs.itheima.com/thread-207208-1-1.html[/url]
****************************************
火车站3：窗口1：(售)：票号：(20150001)余票：299
Exception in thread "火车站4：" Exception in thread "火车站1：" java.lang.IllegalThreadStateException
at java.lang.Thread.start(Thread.java:704)
at review.Depot.run(Depot.java:69)
at java.lang.Thread.run(Thread.java:744)
java.lang.IllegalThreadStateException
at java.lang.Thread.start(Thread.java:704)
at review.Depot.run(Depot.java:69)
at java.lang.Thread.run(Thread.java:744)
Exception in thread "火车站2：" java.lang.IllegalThreadStateException
at java.lang.Thread.start(Thread.java:704)
at review.Depot.run(Depot.java:69)
at java.lang.Thread.run(Thread.java:744)
Exception in thread "火车站3：" java.lang.IllegalThreadStateException
at java.lang.Thread.start(Thread.java:704)
at review.Depot.run(Depot.java:69)
at java.lang.Thread.run(Thread.java:744)
火车站3：窗口1：(售)：票号：(20150002)余票：298

********************
at java.lang.Thread.run(Thread.java:744)
火车站2：窗口1：(售)：票号：(20150002)余票：298
火车站2：窗口1：(售)：票号：(20150003)余票：297
火车站2：窗口1：(售)：票号：(20150004)余票：296
火车站4：窗口[5]：【退】：票号：(20150004)余票：297
火车站1：窗口[6]：【退】：票号：(20150003)余票：298
火车站4：窗口[6]：【退】：票号：(20150002)余票：299
火车站4：窗口[6]：【退】：票号：(20150001)余票：300
Exception in thread "火车站4：窗口[6]：【退】：" Exception in thread "火车站1：窗口[5]：【退】：" java.lang.IllegalMonitorStateException
at java.lang.Object.notify(Native Method)
at review.Depot$SetTicketWindows.run(Depot.java:206)
at java.lang.Thread.run(Thread.java:744)
java.lang.IllegalMonitorStateException
at java.lang.Object.notify(Native Method)
at review.Depot$SetTicketWindows.run(Depot.java:206)
at java.lang.Thread.run(Thread.java:744)
火车站1：窗口4：(售)：票号：(20150001)余票：299
火车站1：窗口4：(售)：票号：(20150002)余票：298

********************
下面是今天补全的火车站类：
测试类在昨天发的帖子里：http://bbs.itheima.com/thread-207208-1-1.html

package review;
import java.util.LinkedList;
/************火车站*************************/
public class Depot implements Runnable{
//TreeSet<Integer> TICKETSS = new TreeSet<Integer>();//火车站车票池
LinkedList<Integer> TICKETSS = new LinkedList<Integer>();//未卖出车票
LinkedList<Integer> NOT_TICKETSS = new LinkedList<Integer>();//已卖出车票
int piaohao = 20150001;
int y = 300;
/*int [] TICKETSS = new int [100];*/
//private int TICKETS = 200;// 定义票数
Depot(){
for(int x = 1;x<=/*TICKETSS.size()*/300;x++){//初始值为100张
TICKETSS.add(piaohao++);
}
}
public void run(){
/* for(int x = 1;x<TICKETSS.size();x++){
TICKETSS.add(x);
}*/
GetTicketWindows gtw = new GetTicketWindows();//售票窗口
SetTicketWindows stw = new SetTicketWindows();//退票窗口
Thread t1 = new Thread(gtw);
Thread t2 = new Thread(gtw);
Thread t3 = new Thread(gtw);
Thread t4 = new Thread(gtw);
Thread t5 = new Thread(stw);
Thread t6 = new Thread(stw);
//Thread t7 = new Thread(stw);
while(true){
//synchronized(Depot.class){
// if(TICKETS > 0){
try {
Thread.sleep(27);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
t1.setName(Thread.currentThread().getName()+"窗口1：(售)：");
t2.setName(Thread.currentThread().getName()+"窗口2：(售)：");
t3.setName(Thread.currentThread().getName()+"窗口3：(售)：");
t4.setName(Thread.currentThread().getName()+"窗口4：(售)：");
t5.setName(Thread.currentThread().getName()+"窗口[5]：【退】：");
t6.setName(Thread.currentThread().getName()+"窗口[6]：【退】：");
//t7.setName(Thread.currentThread().getName()+"窗口[7]：【退】：");
t1.start();
t2.start();
t3.start();
t4.start();
t5.start();
t6.start();
//t7.start();
/* Ting T = new Ting();
Thread ting1 = new Thread();
Thread ting2 = new Thread();
ting1.setName(Thread.currentThread().getName()+"第一大厅：");
ting2.setName(Thread.currentThread().getName()+"第二大厅：");
ting1.start();
ting2.start();*/
//}
//}
}
}
/************售票窗口***********************/
/**售票代码开始**/
private class GetTicketWindows implements Runnable{
public void run() {
// 重写Runnable中的run方法
//int s = 0;
while (true) {
//if (s % 2 == 0) {
/****同步代码块开始******/
synchronized (Depot.class) {
if(/*TICKETSS.isEmpty() */ /*TICKETSS.size()< = y*/y<=0){//如果没有票，那就等待
/* if(y==0){
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}*/
//stw.run();
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
this.notify();
}
}
if (/*TICKETSS.size()*/y > 0) {
try {
Thread.sleep(27);//出票等待时间
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
synchronized(/*GetTicketWindows.class*/Depot.class){
synchronized("A"){
y--;
NOT_TICKETSS.addFirst(TICKETSS.getFirst());//把下面这张卖出去的票增加到已卖出车票列表的第一个位置
System.out.println(Thread.currentThread().getName()
+"票号：("+ TICKETSS.pollFirst() + ")余票："+ (y)/*(TICKETSS.size())"-----同步代码块"*/ );
}
//this.notify();
//TICKETSS.pollFirst();
}
}
}
/******同步代码块结束*******/
//}
//else {
//check();
//}
//s++;
}
}
/***同步方法开始**/
// private synchronized void check() {//静态同步方法的锁是所在类的class对象，动态同步方法的锁为当前调用该方法的对象，也就是this指向的对象
// if (TICKETS > 0) {
// try {
// Thread.sleep(21);
// } catch (InterruptedException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
// System.out.println(Thread.currentThread().getName() + + (TICKETS--)+ "-----同步代方法" );
// }
// }
/***同步方法结束**/
}
/****售票代码结束****/
/*************退票窗口**********************/
class SetTicketWindows implements Runnable{
public void run(){
while(true){
synchronized(Depot.class){
if(y >= 300/* | TICKETSS == null*/){//如果没有票卖出，那就关闭退票窗口
/* if(y==0){
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}*/
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
this.notify();//告诉售票窗口，有票了
}
}
//if(/*(!TICKETSS.isEmpty()) | */y<299 ){//如果有票卖出，那么打开退票窗口
try {
Thread.sleep(27);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
/* for(int x = 1;x<=TICKETSS.size()300;x++){//初始值为100张
TICKETSS.add(x);
}*/
synchronized(/*SetTicketWindows.class*/Depot.class){
synchronized("A"){
y++;
TICKETSS.addFirst(NOT_TICKETSS.getFirst());//把下面的退票增加到未卖出车票列表中的第一个位置
System.out.println(Thread.currentThread().getName()
+"票号：(" + NOT_TICKETSS.pollFirst()+ ")余票："+(y)/*(TICKETSS.size())"-----同步代码块"*/ );
}
//System.out.print( NOT_TICKETSS.pollFirst() );
//System.out.println(")余票："+(y)/*(TICKETSS.size())"-----同步代码块"*/ );
//NOT_TICKETSS.pollFirst();
}
// }
}
}
}
}
}

复制代码

作者: (晶小羊) 时间: 2015-6-25 21:56
很尽力的看了- -请楼下作答- -

作者: (晶小羊) 时间: 2015-6-25 21:58
很尽力的看了- -请楼下作答- -

作者: 空城dream 时间: 2015-6-25 21:58
虽然看不懂，但顶了。。

作者: 0618-蔺飞飞 时间: 2015-6-25 21:58
膜拜一下大神

作者: nine789 时间: 2015-6-25 21:59

空城dream 发表于 2015-6-25 21:58
虽然看不懂，但顶了。。

非常感谢呀

作者: 青皮核桃 时间: 2015-6-25 21:59
其实我也不懂

作者: (晶小羊) 时间: 2015-6-25 22:00
很尽力的看了- -请楼下作答- -

作者: modric14 时间: 2015-6-25 22:03
感觉很厉害的样子

作者: jx5785749 时间: 2015-6-25 22:04
不错顶一个!

作者: keto 时间: 2015-6-25 22:04
表示已看晕@_@

作者: kkss834483739 时间: 2015-6-25 22:09
很尽力的看了- -请楼下作答- -

作者: nine789 时间: 2015-6-25 22:12

(晶小羊) 发表于 2015-6-25 21:56
很尽力的看了- -请楼下作答- -

有了大家的支持，楼下肯定有大神解答的

作者: 进军黑马 时间: 2015-6-25 22:12
默默的顶了

作者: tangpeng 时间: 2015-6-25 22:12
能写这莫多就不错了，不管写的怎么样！

作者: nine789 时间: 2015-6-25 22:13

(晶小羊) 发表于 2015-6-25 21:56
很尽力的看了- -请楼下作答- -

有了大家的支持，楼下肯定会出现大神出来解答的

作者: nine789 时间: 2015-6-25 22:22

0618-蔺飞飞发表于 2015-6-25 21:58
膜拜一下大神

是姐夫吧，:lol

作者: 三樱椒 时间: 2015-6-25 23:37
用不用其他的编绎器？

作者: 木头人之死 时间: 2015-6-26 08:11
表示能不能写注释。。。

作者: 黑马无敌 时间: 2015-6-26 08:54
好长呀。。。。

作者: guiqulaixi 时间: 2015-6-26 12:03
楼主看你的代码真的能哭晕在厕所里面，有一些很基础的东西你都搞错了， java.lang.IllegalThreadStateException
你知道为什么出现这种错么？？ while(true){ ....... t1.start(); t2.start(); ...}你明明已经创建了一堆线程，你让它们一次又一次start()这是什么意思？线程启动只有一次start(),这种低级错误也能犯
第二个异常java.lang.IllegalMonitorStateException是因为你用的锁对象是错误的，你明明设置的锁对象是Depot.class，你却用this去notify和wait，请你好好看下文档，这又是一个低级错误
第三，你加那么多不必要的锁是何意？synchronized("A")这种同步代码块加了意义何在？你明明同步了共享资源
第四，建议你先搞清楚一个火车站多个窗口售票退票问题，在搞多个火车站，我不太清楚你到底想怎样？是各个火车站各自卖自己的300票，还是多个火车站共享一个票源，建议你先把这些问题都想清楚，在写代码。

在你的基础上我改了些代码，是一个火车站的卖票系统，多个火车站我不打算搞
你可以参考下，如有不足，也欢迎指正：

class Depot implements Runnable{
LinkedList<Integer> TICKETSS = new LinkedList<Integer>();//未卖出车票
LinkedList<Integer> NOT_TICKETSS = new LinkedList<Integer>();//已卖出车票
int piaohao = 20150001;
int y = 300;
Depot()
{
for(int x = 1;x<=300;x++){
TICKETSS.add(piaohao++);
}
Iterator<Integer> it = TICKETSS.iterator();
while(it.hasNext())
{
System.out.println(it.next());
}
}
public void run(){
GetTicketWindows gtw = new GetTicketWindows();//售票窗口
SetTicketWindows stw = new SetTicketWindows();//退票窗口
Thread t1 = new Thread(gtw);
Thread t2 = new Thread(gtw);
Thread t3 = new Thread(gtw);
Thread t4 = new Thread(gtw);
Thread t5 = new Thread(stw);
Thread t6 = new Thread(stw);
t1.setName(Thread.currentThread().getName()+"窗口1：(售)：");
t2.setName(Thread.currentThread().getName()+"窗口2：(售)：");
t3.setName(Thread.currentThread().getName()+"窗口3：(售)：");
t4.setName(Thread.currentThread().getName()+"窗口4：(售)：");
t5.setName(Thread.currentThread().getName()+"窗口[5]：【退】：");
t6.setName(Thread.currentThread().getName()+"窗口[6]：【退】：");
//t7.setName(Thread.currentThread().getName()+"窗口[7]：【退】：");
t1.start();
t2.start();
t3.start();
t4.start();
t5.start();
t6.start();
}
/************售票窗口***********************/
/**售票代码开始**/
private class GetTicketWindows implements Runnable{
public void run() {
// 重写Runnable中的run方法
//int s = 0;
while (true) {
/****同步代码块开始******/
synchronized (Depot.class) {//error---java.lang.IllegalMonitorStateException
while(/*TICKETSS.isEmpty() */ /*TICKETSS.size()< = y*/y<=0){//如果没有票，那就等待
try {
Depot.class.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
Depot.class.notifyAll();
}
}
try {
Thread.sleep(27);//出票等待时间
} catch (InterruptedException e) {
e.printStackTrace();
}
y--;
NOT_TICKETSS.addFirst(TICKETSS.poll());//把下面这张卖出去的票增加到已卖出车票列表的第一个位置
System.out.println(Thread.currentThread().getName()
+"票号：("+ NOT_TICKETSS.getFirst() + ")余票："+ (y)/*(TICKETSS.size())"-----同步代码块"*/ );
}
}
}
}
class SetTicketWindows implements Runnable{
public void run(){
while(true){
synchronized(Depot.class){
while(y >= 300)//如果没有票卖出，那就关闭退票窗口
{
try {
Depot.class.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
Depot.class.notifyAll();//告诉售票窗口，有票了
}
}
y++;
TICKETSS.addFirst(NOT_TICKETSS.poll());//把下面的退票增加到未卖出车票列表中的第一个位置
System.out.println(Thread.currentThread().getName()
+"票号：(" + TICKETSS.getFirst()+ ")余票："+(y)/*(TICKETSS.size())"-----同步代码块"*/ );
}
}
}
}
}

复制代码

作者: nine789 时间: 2015-6-27 00:03

guiqulaixi 发表于 2015-6-26 12:03
楼主看你的代码真的能哭晕在厕所里面，有一些很基础的东西你都搞错了， java.lang.IllegalThreadStateExce ...

我已经优化过代码了，如果不是多个火车站，那又有什么意思呢？

这是多线程同步嵌套问题，

但还是感谢你的帮助，一会我把优化过后的代码发上去

作者: nine789 时间: 2015-6-27 00:38

guiqulaixi 发表于 2015-6-26 12:03
楼主看你的代码真的能哭晕在厕所里面，有一些很基础的东西你都搞错了， java.lang.IllegalThreadStateExce ...

不知道这样优化后，你感觉怎么样

但是其中还是会出现一些问题
**********测试类
Depot dt = new Depot();

Thread x1 = new Thread(dt);
Thread x2 = new Thread(dt);
Thread x3 = new Thread(dt);
Thread x4 = new Thread(dt);

x1.setName("北京站：");
x2.setName("广州站：");
x3.setName("携程网：");
x4.setName("12306：");

x1.start();
x2.start();
x3.start();
x4.start();
*************

package review;
import java.util.Calendar;
import java.util.LinkedList;
/************ 火车站 *************************/
public class Depot implements Runnable {
LinkedList<Integer> TICKETSS = new LinkedList<Integer>();// 未卖出车票
LinkedList<Integer> NOT_TICKETSS = new LinkedList<Integer>();// 已卖出车票
int piaohao = 20150001;
static int y = 300;
Depot() {
for (int x = 1; x <= 300; x++) {// 初始值为100张
TICKETSS.add(piaohao);
piaohao++;
}
}
public void run() {
GetTicketWindows gtw = new GetTicketWindows();// 售票窗口
SetTicketWindows stw = new SetTicketWindows();// 退票窗口
Thread t1 = new Thread(gtw);
Thread t2 = new Thread(gtw);
Thread t3 = new Thread(gtw);
Thread t4 = new Thread(gtw);
Thread t5 = new Thread(stw);
Thread t6 = new Thread(stw);
synchronized ("F") {
try {
Thread.sleep(220);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (Thread.currentThread().getName().equals("12306：")
| Thread.currentThread().getName().equals("携程网：")) {
t4.setName(Thread.currentThread().getName() + "(网)：(售)：");
t4.start();
t6.setName(Thread.currentThread().getName() + "(网)：【退】：");
t6.start();
}
if (Thread.currentThread().getName().equals("北京站：")
| Thread.currentThread().getName().equals("广州站：")) {
t1.setName(Thread.currentThread().getName() + "窗口1：(售)：");
t2.setName(Thread.currentThread().getName() + "窗口2：(售)：");
t3.setName(Thread.currentThread().getName() + "窗口3：(售)：");
t5.setName(Thread.currentThread().getName() + "窗口[5]：【退】：");
t1.start();
/*
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception in thread
* "火车站4：" java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
*/
t2.start();
t3.start();
t5.start();
}
}
}
/************ 售票窗口 ***********************/
/** 售票代码开始 **/
private class GetTicketWindows implements Runnable {
public void run() {
while (true) {
if (y <= 0) {// 如果没有票，那就等待
// Thread.yield();
/*
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception in thread
* "火车站4：" java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
*/
try {
this.wait();
/**
* 暂停所有售票线程问题
*/
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// Thread.yield(); //线程等待
}
try {
Thread.sleep(135);// 出票等待时间
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (TICKETSS != null & y > 0) { // 如果卖票池有票，并且数量大于0
String wuzuo = "";
String tiaoshi = "";
Calendar calendar = Calendar.getInstance();
int shi = calendar.get(Calendar.HOUR_OF_DAY);
int fen = calendar.get(Calendar.MINUTE);
int miao = calendar.get(Calendar.SECOND);
int hao = calendar.get(Calendar.MILLISECOND);
if (y >= 180) { // 180--300=120硬座
wuzuo = "****硬座****";
} else if (y >= 160) {// 160--179=20软卧
wuzuo = "****软卧****";
} else if (y >= 110) {// 110--159=50二等座
wuzuo = "****二等座****";
;
} else if (y >= 80) {// 80--109=30硬卧
wuzuo = "****硬卧****";
} else if (y >= 40) {// 40--79=40一等座
wuzuo = "****一等座****";
} else if (y < 40) {
wuzuo = "****无座****";
if (TICKETSS == null) { // 无票
tiaoshi = "------------------------系统调时";
}
}
synchronized ("C") {
if (y == 300) {
y = 300;
}
--y;
if (y >= 0) {
System.out.println(Thread.currentThread().getName()
+ "票号：(-" + TICKETSS.peek() + wuzuo
+ ")余票：" + (y) + tiaoshi + "：当前时间：" + shi
+ ":" + fen + ":" + miao + ":" + hao/*
* (TICKETSS
* .
* size(
* ))
* "-----同步代码块"
*/);
NOT_TICKETSS.addFirst(TICKETSS.pollFirst());// 把下面这张卖出去的票增加到已卖出车票列表的第一个位置
}
}
}
}
}
}
/**** 售票代码结束 ****/
/************* 退票窗口 **********************/
class SetTicketWindows implements Runnable {
public void run() {
while (true) {
if (y >= 300) {// 如果没有票卖出，那就关闭退票窗口
// Thread.yield();
/*
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception in
* thread "火车站4：" java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
*/
try {
this.wait();
/**
* 关闭所有退票窗口
*/
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
this.notify();
/**
* 开启所有售票窗口
*/
}
}
try {
Thread.sleep(317);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (NOT_TICKETSS != null & y > 0) { // 如果退票池有票，并且数量大于0
String tiaoshi2 = "";
Calendar calendar = Calendar.getInstance();
int shi = calendar.get(Calendar.HOUR_OF_DAY);
int fen = calendar.get(Calendar.MINUTE);
int miao = calendar.get(Calendar.SECOND);
int hao = calendar.get(Calendar.MILLISECOND);
if (y < 40) {
// wuzuo2 = "****无座****";
/*
* if(TICKETSS == null ){ //无票 tiaoshi2 =
* "------------------------系统调时"; }
*/
}
synchronized ("C") {
if (y == 300) {
y = 300;
}
++y;
if (y <= 300) {
System.out.println(Thread.currentThread().getName()
+ "票号：【+" + NOT_TICKETSS.peek() + "】余票："
+ (y) + tiaoshi2 + "：当前时间：" + shi + ":"
+ fen + ":" + miao + ":" + hao/*
* (TICKETSS.size
* (
* ))"-----同步代码块"
*/);
TICKETSS.addFirst(NOT_TICKETSS.pollFirst());// 把下面的退票增加到未卖出车票列表中的第一个位置
}
}
}
}
}
}
}

复制代码

作者: guiqulaixi 时间: 2015-6-27 09:53

nine789 发表于 2015-6-27 00:03
我已经优化过代码了，如果不是多个火车站，那又有什么意思呢？

这是多线程同步嵌套问题，

楼主，你到现在对于一些基础的知识都没理解透，就想写复杂的代码，我只能说你自己好自为之吧，优化的代码还是有低级错误，不好意思，实在不想看完了。

作者: nine789 时间: 2015-6-27 21:47

guiqulaixi 发表于 2015-6-27 09:53
楼主，你到现在对于一些基础的知识都没理解透，就想写复杂的代码，我只能说你自己好自为之吧，优化的代 ...

我基础就是不好，算了

作者: 崔司龙 时间: 2015-6-27 22:04
看起来很厉害的样子...

作者: Wait_For 时间: 2015-6-27 22:31
求大神出现啊！

作者: nine789 时间: 2015-6-27 22:44

package Thread_1;
public class ThreadTicketsDemo_1 {
public static void main(String[] args) {
Depot dt = new Depot();
Thread x1 = new Thread(dt);
Thread x2 = new Thread(dt);
Thread x3 = new Thread(dt);
Thread x4 = new Thread(dt);
x1.setName("北京站：");
x2.setName("广州站：");
x3.setName("携程网：");
x4.setName("12306：");
x1.start();
x3.start();
x2.start();
x4.start();
}
}

复制代码

作者: nine789 时间: 2015-6-28 11:19

nine789 发表于 2015-6-27 22:44

package Thread_1;
import java.util.Calendar;
import java.util.LinkedList;
/************ 火车站 *************************/
public class Depot implements Runnable {
LinkedList<Integer> TICKETSS = new LinkedList<Integer>();// 未卖出车票
LinkedList<Integer> NOT_TICKETSS = new LinkedList<Integer>();// 已卖出车票
int piaohao = 20150001;
static int y = 300;
int e = 0;
int d = 0;
Depot() {
for (int x = 1; x <= /* TICKETSS.size() */300; x++) {// 初始值为100张
TICKETSS.add(piaohao);
piaohao++;
}
}
TicketsHall_1 th1 = new TicketsHall_1();
Thread h1 = new Thread(th1);//北京站专用
Thread h2 = new Thread(th1);//广州站专用
Thread h3 = new Thread(th1);//12306专用
//Thread h4 = new Thread(th1);//携程网专用
public void run() {
//TicketsHall_2 th2 = new TicketsHall_2();
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//synchronized("YU"){
if (Thread.currentThread().getName().equals("北京站：")
| Thread.currentThread().getName().equals("广州站：")) {
h1.setName(Thread.currentThread().getName() + "第1售票厅：");
h2.setName(Thread.currentThread().getName() + "第2售票厅：");
/* try {
Thread.sleep(147);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
++e;
h1.start();
// if(e%2==0){
// h1.start();
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
// }
h2.start();
/* if(e%2==0){
++e;
Thread.yield();
}*/
}
if (Thread.currentThread().getName().equals("12306：")
| Thread.currentThread().getName().equals("携程网：")){
h3.setName(Thread.currentThread().getName() + "（网）：");//12306专用
//h4.setName(Thread.currentThread().getName() + "（网）：");
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
/* int XYZ = 0;
if(XYZ%2==0){
h3.start();
++XYZ;
}*/
// if(e%2==1){
// ++e;
// try {
// Thread.sleep(50000);
// } catch (InterruptedException e1) {
// // TODO Auto-generated catch block
// e1.printStackTrace();
// }
// }
h3.start();
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
/* if(d%2==0){
++d;
Thread.yield();
}*/
// Thread.yield();
}
//}
/* GetTicketWindows gtw = new GetTicketWindows();// 售票窗口
SetTicketWindows stw = new SetTicketWindows();// 退票窗口
Thread t5 = null;
Thread t1 = new Thread(gtw);
Thread t2 = new Thread(gtw);
Thread t3 = new Thread(gtw);
Thread t4 = new Thread(gtw);
if (t5 == null) {
t5 = new Thread(stw);
}
Thread t6 = new Thread(stw);
try {
Thread.sleep(220);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (Thread.currentThread().getName().equals("12306：")
| Thread.currentThread().getName().equals("携程网：")) {
if (y > 0) { // 如果有票，那就打开售票窗口
t4.setName(Thread.currentThread().getName() + "(网)：(售)：");
t4.start();
}
if (y <= 300) {// 如果有票卖出，就打开退票功能
t6.setName(Thread.currentThread().getName() + "(网)：【退】：");
t6.start();
}
}
if (Thread.currentThread().getName().equals("北京站：")
| Thread.currentThread().getName().equals("广州站：")) {
if (y > 0) {// 如果有票，我就打开售票窗口
t1.setName(Thread.currentThread().getName() + "窗口1：(售)：");
t2.setName(Thread.currentThread().getName() + "窗口2：(售)：");
t3.setName(Thread.currentThread().getName() + "窗口3：(售)：");
t1.start();
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception in thread
* "火车站4：" java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
t2.start();
t3.start();
}
if (y <= 300) { // 如果有票卖出，那我就打开退票窗口
t5.setName(Thread.currentThread().getName() + "窗口[5]：【退】：");
// t7.setName(Thread.currentThread().getName()+"窗口[7]：【退】：");
t5.start();
// t7.start();
}
}*/
}
/***********第一售票厅**************/
private class TicketsHall_1 implements Runnable{
GetTicketWindows gtw1 = new GetTicketWindows();// 售票窗口
SetTicketWindows stw1 = new SetTicketWindows();// 退票窗口
Thread t1 = new Thread(gtw1);
Thread t2 = new Thread(gtw1);
Thread t3 = new Thread(gtw1);
Thread t4 = new Thread(gtw1);
Thread t5 = new Thread(stw1);
Thread t6 = new Thread(stw1);
public void run(){
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//synchronized("YU"){
if (Thread.currentThread().equals(h3)) {///////////////////////////////////////////////////////////////////
if (y > 0) { // 如果有票，那就打开售票窗口
t4.setName(Thread.currentThread().getName() + "自助：(售)：");
t4.start();
}
if (y <= 300) {// 如果有票卖出，就打开退票功能
t6.setName(Thread.currentThread().getName() + "自助：【退】：");
t6.start();
}
}
if (Thread.currentThread().equals(h1)
| Thread.currentThread().equals(h2)) {
if (y > 0) {// 如果有票，我就打开售票窗口
t1.setName(Thread.currentThread().getName() + "窗口1：(售)：");
t2.setName(Thread.currentThread().getName() + "窗口2：(售)：");
t3.setName(Thread.currentThread().getName() + "自助1：(售)：");
t1.start();
/*
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception in thread
* "火车站4：" java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
*/
t2.start();
t3.start();
}
if (y <= 300) { // 如果有票卖出，那我就打开退票窗口
// t7.setName(Thread.currentThread().getName()+"窗口[7]：【退】：");
t5.setName(Thread.currentThread().getName() + "窗口[3]：【退】：");
t5.start();
// t7.start();
}
}
//}
}
}
/***********第一售票厅*结束*************/

复制代码

作者: nine789 时间: 2015-6-28 11:20

nine789 发表于 2015-6-28 11:19

/***********第一售票厅*结束*************/
/************ 售票窗口 ***********************/
/** 售票代码开始 **/
private class GetTicketWindows implements Runnable {
public void run() {
if (y > 0) { // 如果有票就打开售票系统
while (true) {
if (/* TICKETSS.isEmpty() *//* TICKETSS.size()< = y */y <= 0) {// 如果没有票，那就等待
// Thread.yield();
/*
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception
* in thread "火车站4："
* java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
*/
}
try {
Thread.sleep((long) (Math.random()*100));// 出票等待时间
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (TICKETSS != null & y > 0) { // 如果卖票池有票，并且数量大于0
String wuzuo = "";
String tiaoshi = "";
Calendar calendar = Calendar.getInstance();
int shi = calendar.get(Calendar.HOUR_OF_DAY);
int fen = calendar.get(Calendar.MINUTE);
int miao = calendar.get(Calendar.SECOND);
int hao = calendar.get(Calendar.MILLISECOND);
if (y >= 180) { // 180--300=120硬座
wuzuo = "****硬座****";
} else if (y >= 160) {// 160--179=20软卧
wuzuo = "****软卧****";
} else if (y >= 110) {// 110--159=50二等座
wuzuo = "****二等座****";
;
} else if (y >= 80) {// 80--109=30硬卧
wuzuo = "****硬卧****";
} else if (y >= 40) {// 40--79=40一等座
wuzuo = "****一等座****";
} else if (y < 40) {
wuzuo = "****无座****";
if (TICKETSS == null) { // 无票
tiaoshi = "------------------------系统调时";
}
}
/**** 同步代码块开始 ******/
synchronized ("C") {
if (y == 300) {
y = 300;
}
--y;
if (y >= 0) {
System.out.println(Thread.currentThread()
.getName()
+ "票号：(-"
+ TICKETSS.peek()
+ wuzuo
+ ")余票："
+ (y)
+ tiaoshi
+ "：当前时间："
+ shi
+ ":"
+ fen
+ ":"
+ miao + ":" + hao/*
* (TICKETSS.size())
* "-----同步代码块"
*/);
NOT_TICKETSS.addFirst(TICKETSS.pollFirst());// 把下面这张卖出去的票增加到已卖出车票列表的第一个位置
try {// 出票等待
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (y == 0) {
// Thread.stop();
break;
}
} else {
++y;
System.out.println("其他线程可能执行到的语句"
+ Thread.currentThread().getName()
+ "余票：" + y);
// 内测
}
}
/****** 同步代码块结束 *******/
}
}// while结束
/*********** 内测开始 **************/
System.out.println(Thread.currentThread().getName()
+ "票已售完，请等待(1)");
{
System.out.println(Thread.currentThread().getName()
+ "票已售完，请等待(2)");
// stw.run();
// det.stw.run();
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// Depot.run();
}
/*********** 内测结束 ***************/
}// if 结束
System.out
.println(Thread.currentThread().getName() + "票已售完，请等待(3)"); // 内测
}// run结束
/*** 同步方法开始 **/
// private synchronized void check()
// {//静态同步方法的锁是所在类的class对象，动态同步方法的锁为当前调用该方法的对象，也就是this指向的对象
// if (TICKETS > 0) {
// try {
// Thread.sleep(21);
// } catch (InterruptedException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
// System.out.println(Thread.currentThread().getName() + + (TICKETS--)+
// "-----同步代方法" );
// }
// }
/*** 同步方法结束 **/
}
/**** 售票代码结束 ****/
/************* 退票窗口 **********************/
private class SetTicketWindows implements Runnable {
public void run() {
while (true) {
if (y >= 300/* | TICKETSS == null */) {// 如果没有票卖出，那就关闭退票窗口
Thread.yield();
/*
* 多线程嵌套同步问题火车站3：窗口[5]：【退】：票号：【+null】余票：301 Exception in
* thread "火车站4：" java.lang.IllegalThreadStateException at
* java.lang.Thread.start(Thread.java:704) at
* review.Depot.run(Depot.java:71) at
* java.lang.Thread.run(Thread.java:744)
* 火车站3：窗口4：(售)：票号：(-null)余票：300
*/
}
try {
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (NOT_TICKETSS != null & y > 0) { // 如果退票池有票，并且数量大于0
String tiaoshi2 = "";
Calendar calendar = Calendar.getInstance();
int shi = calendar.get(Calendar.HOUR_OF_DAY);
int fen = calendar.get(Calendar.MINUTE);
int miao = calendar.get(Calendar.SECOND);
int hao = calendar.get(Calendar.MILLISECOND);
if (y < 40) {
// wuzuo2 = "****无座****";
/*
* if(TICKETSS == null ){ //无票 tiaoshi2 =
* "------------------------系统调时"; }
*/
}
synchronized ("C") {
if (y >= 300) {
y = 300;
}
++y;
if (y <= 300) {
System.out.println(Thread.currentThread().getName()
+ "票号：【+" + NOT_TICKETSS.peek() + "】余票："
+ (y) + tiaoshi2 + "：当前时间：" + shi + ":"
+ fen + ":" + miao + ":" + hao/*
* (TICKETSS.size
* (
* ))"-----同步代码块"
*/);
TICKETSS.addFirst(NOT_TICKETSS.pollFirst());// 把下面的退票增加到未卖出车票列表中的第一个位置
try {// 出票等待
Thread.sleep((long) (Math.random()*100));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (y == 0) {
// Thread.stop();
break;
}
} else {
--y;
System.out.println("其他线程可能执行到的语句"
+ Thread.currentThread().getName() + "余票："
+ y);
}
}
}
}
}
}
}

复制代码

欢迎光临黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2