sdfsdf

黄兴旺

本帖最后由张聪珉于 2019-9-11 14:14 编辑

sdfsdfsdfsdfsdfsdf

薛淑凯 · 薛淑凯

这样做的结果就是同样的票卖了三次，一共三百张

毋须繁华 · 毋须繁华

为什么不写注释- - 看不懂啊

张聪珉 · 张聪珉

薛淑凯发表于 2013-9-3 21:59
这样做的结果就是同样的票卖了三次，一共三百张

哥们，那我应该怎么实现啊，加同步代码块，求您知道，要是可以加上代码解析就万分感谢了

薛淑凯 · 薛淑凯

张聪珉发表于 2013-9-3 23:22
哥们，那我应该怎么实现啊，加同步代码块，求您知道，要是可以加上代码解析就万分感谢了
...

多个线程共享同一个数据，要么使用同一个Runnable对象，要么将这个共享数据进行封装然后加锁访问。修改后的代码

//package com.itheima;
import java.util.ArrayList;
import java.util.Collections;
/*5、编写三各类Ticket、SealWindow、TicketSealCenter分别代表票信息
* 、售票窗口、售票中心。售票中心分配一定数量的票，由若干个售票窗口进行出售，
* 利用你所学的线程知识来模拟此售票过程。
*
* 需求分析：Ticket包含有票名和票号
* TicketSealCenter是唯一的采用单例模式设计，有makeTickets生产票方法，和putTickets分配票方法
* SealWindow实现Runnable接口，覆盖run方法，构造函数接受String窗口名称以及Ticket[] tickets票数
*/
public class Test5 {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
TicketSealCenter tsl=TicketSealCenter.getInstance();
tsl.makeTickets("上海---北京", 100);
Ticket[] tickets=tsl.putTickets();
//创建三个卖票窗口每个窗口分配100张票
/*SealWindow sealWindow1=new SealWindow("1号窗口",tickets);
SealWindow sealWindow2=new SealWindow("2号窗口",tickets);
SealWindow sealWindow3=new SealWindow("3号窗口",tickets);
new Thread(sealWindow1).start();
new Thread(sealWindow1).start();
new Thread(sealWindow1).start();*///这种方式最简单，使用同一个窗口实例，run方法加锁就行了，其他不需要修改
SealWindow sealWindow1=new SealWindow("1号窗口",tsl);
SealWindow sealWindow2=new SealWindow("2号窗口",tsl);
SealWindow sealWindow3=new SealWindow("3号窗口",tsl);
new Thread(sealWindow1).start();
new Thread(sealWindow2).start();
new Thread(sealWindow3).start();//这种方式把共享数据封装访问，参数改成售票中心，每卖出一张票
//售票中心里的票就少一张，以此类推
}
}
class SealWindow implements Runnable{
private String windowName;
//private Ticket[] tickets;
private TicketSealCenter tsc=null;
public SealWindow(String windowName,TicketSealCenter tsc){
this.windowName=windowName;
//this.tickets=tickets;
this.tsc=tsc;
}
@Override
public void run() {
/*for(int i=0;i<tickets.length;i++){
tickets[i].setId(id--);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
}
System.out.println(windowName+"卖出了:"+tickets[i]);
}*/
while(tsc.isEnd()){
synchronized (tsc) {//这个锁保证原子性，避免出现打印语句后被挂起的错误
System.out.print(windowName);
tsc.sellTicket();
}
try {
Thread.sleep(10);
} catch (InterruptedException e) {
}
}
System.out.println("车票售罄");
}
}
class TicketSealCenter{
private TicketSealCenter(){}
private static TicketSealCenter tsl = new TicketSealCenter();
public static TicketSealCenter getInstance() {
return tsl;
}
private String ticketName;
private int number;
private Ticket[] tickets;
public void makeTickets(String ticketName,int number){
ArrayList<Ticket> al= new ArrayList<Ticket>();
//tickets=new Ticket[number];
for(int i=1;i<=number;i++){
Ticket ticket=new Ticket(ticketName,i);
al.add(ticket);
tickets=al.toArray(new Ticket[al.size()]);
}
}
public Ticket[] putTickets(){
return tickets;
}
private int i=0;
public synchronized void sellTicket(){//定义的售票方法，需要加锁
if(i<tickets.length){
int ticketNum=i+1;
System.out.println("卖出了"+ ticketNum +"号票");
tickets[i]=null;
i++;
}
}
public boolean isEnd(){//判断是否售罄
if(i>=tickets.length)
return false;
return true;
}
}
class Ticket {
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
private String name;
private int id ;
Ticket(String name, int id) {
this.name = name;
this.id = id;
}
public String toString() {
return this.name + "......" + this.id;
}
}

复制代码

张聪珉 · 张聪珉

薛淑凯发表于 2013-9-4 11:25
多个线程共享同一个数据，要么使用同一个Runnable对象，要么将这个共享数据进行封装然后加锁访问。修改后 ...

谢谢哈，哥们你的代码比我的号，我有写了一次，还是没用使用同步但是感觉有漏洞，再看看哈

package com.itheima;
/*第5题：编写三各类Ticket、SealWindow、TicketSealCenter分别代表票信息
* 、售票窗口、售票中心。售票中心分配一定数量的票，由若干个售票窗口进行出售，
* 利用你所学的线程知识来模拟此售票过程。
*
* 需求分析：Ticket包含有票名和票号，String name和int id
* TicketSealCenter是唯一的，采用单例模式设计，有makeTickets生产票方法其接收三个参数分别是票名、票数、以及票号，
* 和putTickets分配票方法。
* SealWindow实现Runnable接口，覆盖run方法，构造函数接受String窗口名称以及Ticket[] tickets票数
*/
import java.util.ArrayList;
public class Test5 {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
TicketSealCenter tsl=TicketSealCenter.getInstance();
//生产100张编号从1开始的"上海---北京"的票
tsl.makeTickets("上海---北京", 100,1);
//获取编号从1开始的"上海---北京"的100张票
Ticket[] tickets1=tsl.putTickets();
//生产100张编号从101开始的"上海---北京"的票
tsl.makeTickets("上海---北京", 100,101);
//获取编号从101开始的"上海---北京"的100张票
Ticket[] tickets2=tsl.putTickets();
//生产100张编号从201开始的"上海---北京"的票
tsl.makeTickets("上海---北京", 100,201);
//获取编号从201开始的"上海---北京"的100张票
Ticket[] tickets3=tsl.putTickets();
//创建三个卖票窗口每个窗口分配100张票
SealWindow sealWindow1=new SealWindow("1号窗口",tickets1);
SealWindow sealWindow2=new SealWindow("2号窗口",tickets2);
SealWindow sealWindow3=new SealWindow("3号窗口",tickets3);
//开启三个窗口线程开始卖票
new Thread(sealWindow1).start();
new Thread(sealWindow2).start();
new Thread(sealWindow3).start();
}
}
class SealWindow implements Runnable{
private String windowName;
private Ticket[] tickets;
public SealWindow(String windowName,Ticket[] tickets){
this.windowName=windowName;
this.tickets=tickets;
}
@Override
public void run() {
// TODO Auto-generated method stub
// 获取每个窗口的总票数
int num=tickets.length;
for(int i=0;i<tickets.length;i++){
//下面文档注释可有可无，只是为了更为直观的观看测试结果的准确性而写的代码
/*try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}*/
//此处创建一个StringBuilder是为了把剩余的票数放进字符串缓冲区里变成字符串打印出来，方便观看结果
//当然，如果不需要获得剩余的票数，此处StringBuilder以及放进StringBuilder的数据都可以不写
StringBuilder sb=new StringBuilder();
sb.append(num-1);
System.out.println(windowName+"卖出了一张 "+tickets[i]+"...剩下"+sb.toString()+"票");
//清空缓冲区
sb.delete(0, 1);
//每卖一张票就减少一张票
num=num-1;
}
/*for(Ticket ticket:tickets)
System.out.println(windowName+"卖出了:"+ticket);*/
}
}
class TicketSealCenter{
private TicketSealCenter(){}
private static TicketSealCenter tsl = new TicketSealCenter();
public static TicketSealCenter getInstance() {
return tsl;
}
private Ticket[] tickets;
//makeTickets方法接收三个参数分别是票名、票数、以及票号
public void makeTickets(String ticketName,int number,int id){
ArrayList<Ticket> al= new ArrayList<Ticket>();
//tickets=new Ticket[number];
for(int i=1;i<=number;i++){
//遍历票数生产对应的票
Ticket ticket=new Ticket(ticketName,id++);
al.add(ticket);
tickets=al.toArray(new Ticket[al.size()]);
}
}
public Ticket[] putTickets(){
return tickets;
}
}
class Ticket {
private String name;
private int id ;
Ticket(String name, int id) {
this.name = name;
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String toString() {
return this.name + "的票，票号为" + this.id;
}
}

复制代码

张亚军 · 张亚军

买票必须是多线程，使用线程同步技术。。。。。。

/*
* 卖票的实例
* 100张票，4个线程同时模拟卖票
*
*
  |-- 定义类，实现Runnable接口
  |-- 覆盖接口的抽象方法 run
  |-- 建立Thread对象，在Thread构造方法中，传递Runnable接口的实现类对象
  |-- 调用Thread对象start()方法

*/
class Ticket implements Runnable{
private int tickets = 100;//定义100张抛
public void run(){
while(true){
if(tickets>0){
try{
Thread.sleep(5);
}catch(InterruptedException e){}
System.out.println(Thread.currentThread().getName()+"卖出第。。。"+tickets--);
}
}
}
}
public class ThreadDemo1 {

public static void main(String[] args) {
// public Thread(Runnable target)=new Ticket
Ticket t = new Ticket();
Thread t0 = new Thread(t);
Thread t1 = new Thread(t);
Thread t2 = new Thread(t);
Thread t3 = new Thread(t);

t0.start();
t1.start();
t2.start();
t3.start();
}

}

Development... · Development...

synchronized 和 lock都可以锁住的

帐号		自动登录	找回密码
密码			加入黑马

sdfsdf

评分

7 个回复

评分

评分