java多线程问题

黄玉昆

本帖最后由张号于 2013-3-15 12:04 编辑

创建了6个线程，同步后为什么总是只有一个线程在走？

/售票窗口
public class SealWindow
{
public static void main(String[] args)
{
new Thread(new TicketSealCenter(), "1号窗口").start();
new Thread(new TicketSealCenter(), "2号窗口").start();
new Thread(new TicketSealCenter(), "3号窗口").start();
new Thread(new TicketSealCenter(), "4号窗口").start();
new Thread(new TicketSealCenter(), "5号窗口").start();
new Thread(new TicketSealCenter(), "6号窗口").start();
}
}
// 售票中心
class TicketSealCenter implements Runnable
{
private void sale() throws Exception
{
Ticket ticket = new Ticket();
// 售票中心分配火车票
ticket.setTicketNum(100);
while (ticket.isEmple())
{
System.out.println(Thread.currentThread().getName() + "售出一张"
+ "还剩下" + ticket.getTicketNum() + "张票");
if (ticket.getTicketNum() == 0)
{
System.out.println("票已经卖完了，明天再来吧！！！");
}
}
}
@Override
public void run()
{
try
{
synchronized (TicketSealCenter.class)
{
sale();
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
// 火车票类
class Ticket
{
private int ticketNum; // 火车票张数
// 获得火车票的数量
public int getTicketNum()
{
return ticketNum;
}
// 设置火车票数量
public void setTicketNum(int ticketNum)
{
this.ticketNum = ticketNum;
}
// 判断是否有票
public boolean isEmple() throws Exception
{
if (ticketNum > 0)
{
ticketNum--;
Thread.sleep(1000);
return true;
}
else
{
System.exit(0);
return false;
}
}
}

复制代码

HM赵磊 · HM赵磊

[ 本帖最后由 csatshell 于 2013-3-13 22:49 编辑 ]\n\n兄弟，你的程序运行后，只有1号窗口买票，原因是你的同步代码块的锁选择的问题看如下代码（更改你的锁标志）

                                    //售票窗口
public class SealWindow
{
      public static void main(String[] args)
      {
            new Thread(new TicketSealCenter(), "1号窗口").start();
            new Thread(new TicketSealCenter(), "2号窗口").start();
            new Thread(new TicketSealCenter(), "3号窗口").start();
            new Thread(new TicketSealCenter(), "4号窗口").start();
            new Thread(new TicketSealCenter(), "5号窗口").start();
            new Thread(new TicketSealCenter(), "6号窗口").start();       }}// 售票中心
class TicketSealCenter implements Runnable
{       private void sale() throws Exception
      {
            Ticket ticket = new Ticket();
            // 售票中心分配火车票
            ticket.setTicketNum(100);             while (ticket.isEmple())
            {

                     System.out.println(Thread.currentThread().getName() + "售出一张"
                                    + "还剩下" + ticket.getTicketNum() + "张票");

                     if (ticket.getTicketNum() == 0)
                     {
                              System.out.println("票已经卖完了，明天再来吧！！！");
                     }             }
      }       //@Override
  Object obj=new Object();//添加的
      public void run()
      {
            try
            {
                     synchronized (obj)
                     {

                              sale();
                     }             }
            catch (Exception e)
            {
                     e.printStackTrace();
            }
      }
}// 火车票类
class Ticket
{       private int ticketNum; // 火车票张数       // 获得火车票的数量
      public int getTicketNum()
      {
            return ticketNum;
      }       // 设置火车票数量
      public void setTicketNum(int ticketNum)
      {
            this.ticketNum = ticketNum;
      }       // 判断是否有票
      public  boolean isEmple() throws Exception
      {             if (ticketNum > 0)
            {                      ticketNum--;
                     Thread.sleep(1);
                     return true;
            }
            else
            {
                     System.exit(0);
                     return false;
            }
      }}

马甲大王 · 马甲大王

本帖最后由张栓紧于 2013-3-13 23:00 编辑

public class SealWindow
{
public static void main(String[] args)
{
new Thread(new TicketSealCenter(), "1号窗口").start();
new Thread(new TicketSealCenter(), "2号窗口").start();
new Thread(new TicketSealCenter(), "3号窗口").start();
new Thread(new TicketSealCenter(), "4号窗口").start();
new Thread(new TicketSealCenter(), "5号窗口").start();
new Thread(new TicketSealCenter(), "6号窗口").start();
}
}
// 售票中心
class TicketSealCenter implements Runnable
{
// 售票中心分配火车票
private void sale() throws Exception
{
Ticket ticket = new Ticket();
ticket.setTicketNum(10);
while (ticket.isEmple())
{
System.out.println(Thread.currentThread().getName() + "售出一张"
+ "还剩下" + ticket.getTicketNum() + "张票");
if (ticket.getTicketNum() == 0)
{
System.out.println("票已经卖完了，明天再来吧！！！");
}
}
}
@Override
public void run()
{
try
{
synchronized (this)
{
sale();
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
// 火车票类
class Ticket
{
private int ticketNum; // 火车票张数
// 获得火车票的数量
public int getTicketNum()
{
return ticketNum;
}
// 设置火车票数量
public void setTicketNum(int ticketNum)
{
this.ticketNum = ticketNum;
}
// 判断是否有票
public boolean isEmple() throws Exception
{
if (ticketNum > 0)
{
ticketNum--;
Thread.sleep(1000);
return true;
}
else
{
System.exit(0);
return false;
}
}
}

复制代码

你把TicketSealCenter类锁死了，所以就只是一个线程在运行

filter · filter

失眠了，半夜来论坛逛下，我修改了下并测试了下代码，至少是能保证安全问题，肯定是可以优化的，明天有空的话我再来看看，希望别的同学帮着优化下

package com.itheima;
public class Test11
{
public static void main(String[] args)
{
[color=Red]Ticket1 ticket = new Ticket1(100);//初始化票的数量[/color]
new Thread(new TicketSealCenter1(ticket), "1号窗口").start();
new Thread(new TicketSealCenter1(ticket), "2号窗口").start();
new Thread(new TicketSealCenter1(ticket), "3号窗口").start();
new Thread(new TicketSealCenter1(ticket), "4号窗口").start();
new Thread(new TicketSealCenter1(ticket), "5号窗口").start();
new Thread(new TicketSealCenter1(ticket), "6号窗口").start();
}
}
// 售票中心
class TicketSealCenter1 implements Runnable
{
// 售票中心分配火车票
[color=Red]private Ticket1 ticket;//Ticket对象最好定义在成员位置上[/color]
//ticket.setTicketNum(100);
TicketSealCenter1(Ticket1 ticket){
this.ticket = ticket;
}
private void sale() throws Exception
{
//Ticket1 ticket = new Ticket1();
// ticket.setTicketNum(100);
while (ticket.isEmple())
{
[color=Red]int count = ticket.getTicketNum();//定义临时变量，记录票的数量[/color]
System.out.println(Thread.currentThread().getName()
+ "售出一张" + "还剩下" + count
+ "张票");
if (count == 0) {
System.out.println("票已经卖完了，明天再来吧！！！");
}
}
}
@Override
public void run()
{
try
{
[color=Red]synchronized (this)//方法的锁最好定义为调用者this[/color] {
sale();
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
// 火车票类
class Ticket1
{
private int ticketNum = 100; // 火车票张数
Ticket1(int ticketNum){
this.ticketNum = ticketNum;
}
// 获得火车票的数量
[color=Red]public synchronized int getTicketNum()//被多条线程操作的数据，要加同步[/color] {
return --ticketNum;
}
// 设置火车票数量
public void setTicketNum(int ticketNum)
{
this.ticketNum = ticketNum;
}
// 判断是否有票
[color=Red] public synchronized boolean isEmple() throws Exception//被多条线程操作的数据，要加同步[/color] {
if (ticketNum > 0)
{
Thread.sleep(1000);
return true;
}
else
{
System.exit(0);
return false;
}
}
}

复制代码

filter · filter

我去，论坛还玩儿不转，怎么设置注释的字体啊？？{:soso_e127:}

李辉 · 李辉

本帖最后由李辉于 2013-3-14 02:16 编辑

这里的问题不少啊！
第一点：最重要的也是最根本的问题是对多线程共享资源的不理解！除了李志阳，前几位创建的线程完全没有共享资源，每个线程都独立的拥有100张票（有一个人定义了10张），我要在这里说清楚恐怕得写太多。大家自己先好好学学。
第二点：类名。包含主函数的类才应该叫“TicketSealCenter“ 因为是这个类运行的时候创建了多个线程并且在调度这些线程，每个线程代表一个售票窗口。实现Runnable接口的类应该叫“SealWindow”。类名不单单是个单词，它代表着你对售票模型以及面向对象的理解。
第三点：同步的理解。同步是防止一个线程对共享数据操作一半的时候另一个线程开始操作。前几位都没有共享数据，同步只能起到一个作用：就是降低程序运行速度。

0.00 · 0.00

表示弄了很久还是没弄好，起床再搞了，困死了都天亮了，
你代码存在很多问题，正如楼上所说，锁只是锁共享的数据，而数据只有票在变，要锁住票，还有一个就是多线程不能像你那样传对象，那样的对象是独立的线程了，
需要同时传同一个对象进去！

filter · filter

楼上说的很到位，给你提供了思路，具体问题还是你自己解决吧，另外我多线程学的也不是很好，最后加的锁是嵌套的死锁，只卖几百张票可能还行，多了就出大问题了
，可能跟设计的方法有关吧
晚上再来看下

0.00 · 0.00

public class SaleWindow
{
   public static void main(String[] args)
   {
Thread t1=new Thread(new TicketSealCenter("1号窗口"));
Thread t2=new Thread(new TicketSealCenter("2号窗口"));
Thread t3=new Thread(new TicketSealCenter("3号窗口"));
Thread t4=new Thread(new TicketSealCenter("4号窗口"));
Thread t5=new Thread(new TicketSealCenter("5号窗口"));
Thread t6=new Thread(new TicketSealCenter("6号窗口"));
t1.start();t2.start();t3.start();t4.start();t5.start();t6.start();

System.out.println("关门下班");
}
}
//新建一个类
class  TicketSealCenter implements Runnable
{
private String iname;

private static int inumber=100;

Object o=new Object();

public  void run()
{
if(inumber>0)
   { while(true)
{
synchronized (o)
      {
if(inumber>0)
{
   System.out.println(this.getIname()+"火车票卖出一张,"+"剩余"+--inumber+"张.");
   try
      {Thread.sleep(1);}
   catch (Exception e)
{System.out.println("系统异常");}
} else
   break;
}

      }

   }

   }

public String getIname()
   {
return iname;
   }
TicketSealCenter(String iname)
   {
   this.iname=iname;
   }

}
你试试这个代码

0.00 · 0.00

还是没锁住，坐等大神出现

0.00 · 0.00

把锁的对象改为类名.class，否则不是同一个锁

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

java多线程问题

点评

评分

10 个回复

评分

评分

评分

评分