AI 助理
备案控制台
开发者社区 数据库 文章 正文

Java:多线程模拟多站点售票过程

2017-11-15 1335
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
这是一个在并发状态下对共享资源的多线程访问。这些访问必须是互斥的进行，因为涉及到对资源的修改。假设现在销售火车票。目的地有 3 个，分别是北京，天津和上海。使用一个枚举类型表示。
Destation.java
package  com.zj.tickets;
 
public   enum  Destation {
     BEIJING ,  SHANGHAI ,  TIANJING
}
下面设计车票类， final   int   original 表示车票基数； int   current 表示当前还有多少张票； Destation  destation 表示目的地，它必须从上面的枚举型中取出其一。
Ticket.java
package  com.zj.tickets;
 
public   class  Ticket {
     private   final   int   original ;
     private   int   current ;
     private   final  Destation  destation ;
 
     public  Ticket( int  nums, Destation where) {
        current  =  original  = nums;
        destation  = where;
    }
 
     public   int  degress() {
        return  -- current ;
    }
 
     public   int  original() {
        return   original ;
    }
 
     public   boolean  soldout() {
        return   current  <= 0;
    }
 
     public  Destation getDestation() {
        return   destation ;
    }
 
     public   int  getCurrent() {
        return   current ;
    }
}
下面设计售票厅类， Map<Destation, Ticket>  tickets 表示目前可销售的车票种类，它通过一个 static 块初始化。 Map<Destation, Integer>  records 是当前售票厅的火车票销售情况。 List<BookingOffice>  offices 表示当前可工作的所有售票厅，每个售票厅是一个线程。 int   ticketsSold 表示当前售票厅售出的火车票总数。 int   id 表示当前售票厅编号。
每个线程都会模拟客户买票、工作人员查询数据库和售票交易过程。
模拟的数据为，当前发往北京、上海和天津的火车票各 5 张；每个售票厅交易 5 次（无论交易成功或失败）后关闭。
BookingOffice.java
package  com.zj.tickets;
import  java.util.ArrayList;
import  java.util.HashMap;
import  java.util.List;
import  java.util.Map;
import  java.util.Random;
import  java.util.concurrent.TimeUnit;
 
public   class  BookingOffice  implements  Runnable {
     private   static  Map<Destation, Ticket>  tickets  =  new  HashMap<Destation, Ticket>();
     private  Map<Destation, Integer>  records ;
     private   static  List<BookingOffice>  offices  =  new  ArrayList<BookingOffice>();
     private   int   ticketsSold  = 0;
     private   final   int   id ;
 
     // now today's tickets for sell:
     static  {
        tickets .put(Destation. BEIJING ,  new  Ticket(5, Destation. BEIJING ));
        tickets .put(Destation. SHANGHAI ,  new  Ticket(5, Destation. SHANGHAI ));
        tickets .put(Destation. TIANJING ,  new  Ticket(5, Destation. TIANJING ));
    }
 
     public  BookingOffice( int  id) {
        this . id  = id;
        offices .add( this );
       resetRecords();
    }
 
     private   void  resetRecords() {
        records  =  new  HashMap<Destation, Integer>();
    }
 
     private   void  addRecords(Destation d) {
       Integer freq =  records .get(d);
        records .put(d, freq ==  null  ? 1 : freq + 1);
    }
 
     public   void  run() {
        int  transaction = 5;
        while  (transaction-- > 0) {
            // simulate a customer's coming:
           Destation d = Destation.values()[ new  Random().nextInt(Destation
                  .values(). length )];
           print( this  +  "i want a ticket for "  + d);
            // simulate the officer's checking:
            try  {
              TimeUnit. SECONDS .sleep(1);
           }  catch  (InterruptedException e) {
              e.printStackTrace();
           }
            // simulate the transaction:
           Ticket wanted =  tickets .get(d);
            synchronized  ( wanted ) {
               if  (!wanted.soldout()) {
                  print( this  +  "sold a ticket for "  + d);
                  wanted.degress();
                  addRecords(d);
                  ++ ticketsSold ;
                  print( this  +  ""  + d +  " tickets still have "
                         + wanted.getCurrent());
              }  else
                  print( this  +  "tickets for "  + d +  " have been sold out." );
           }
       }
       print( this  +  "closed" );
       print( this  +  "totally sold tickets:"  +  ticketsSold  +  ",sell records:"
              +  records );
    }
 
     public   synchronized   int  getValue() {
        return   ticketsSold ;
    }
 
     public  String toString() {
        return   "<Officce-"  +  id  +  ">" ;
    }
 
     static   void  print(String s) {
       System. out .println(s);
    }
}
模拟售票过程如下，启动 5 个售票厅。
Sell.java
package  com.zj.tickets;
import  java.util.concurrent.ExecutorService;
import  java.util.concurrent.Executors;
 
public   class  Sell {
     public   static   void  main(String[] args)  throws  Exception {
       ExecutorService exec = Executors.newCachedThreadPool();
        for  ( int  i = 0; i < 5; i++)
           exec.execute( new  BookingOffice(i));
       exec.shutdown();
    }
}
结果：
<Officce-0>i want a ticket for BEIJING
<Officce-1>i want a ticket for SHANGHAI
<Officce-2>i want a ticket for TIANJING
<Officce-3>i want a ticket for SHANGHAI
<Officce-4>i want a ticket for SHANGHAI
<Officce-0>sold a ticket for BEIJING
<Officce-0>BEIJING tickets still have 4
<Officce-0>i want a ticket for TIANJING
<Officce-1>sold a ticket for SHANGHAI
<Officce-1>SHANGHAI tickets still have 4
<Officce-1>i want a ticket for SHANGHAI
<Officce-2>sold a ticket for TIANJING
<Officce-2>TIANJING tickets still have 4
<Officce-2>i want a ticket for BEIJING
<Officce-3>sold a ticket for SHANGHAI
<Officce-3>SHANGHAI tickets still have 3
<Officce-3>i want a ticket for TIANJING
<Officce-4>sold a ticket for SHANGHAI
<Officce-4>SHANGHAI tickets still have 2
<Officce-4>i want a ticket for BEIJING
<Officce-4>sold a ticket for BEIJING
<Officce-4>BEIJING tickets still have 3
<Officce-4>i want a ticket for SHANGHAI
<Officce-3>sold a ticket for TIANJING
<Officce-3>TIANJING tickets still have 3
<Officce-3>i want a ticket for TIANJING
<Officce-2>sold a ticket for BEIJING
<Officce-2>BEIJING tickets still have 2
<Officce-2>i want a ticket for BEIJING
<Officce-1>sold a ticket for SHANGHAI
<Officce-1>SHANGHAI tickets still have 1
<Officce-1>i want a ticket for SHANGHAI
<Officce-0>sold a ticket for TIANJING
<Officce-0>TIANJING tickets still have 2
<Officce-0>i want a ticket for SHANGHAI
<Officce-4>sold a ticket for SHANGHAI
<Officce-4>SHANGHAI tickets still have 0
<Officce-4>i want a ticket for BEIJING
<Officce-3>sold a ticket for TIANJING
<Officce-3>TIANJING tickets still have 1
<Officce-3>i want a ticket for BEIJING
<Officce-2>sold a ticket for BEIJING
<Officce-2>BEIJING tickets still have 1
<Officce-2>i want a ticket for SHANGHAI
<Officce-1>tickets for SHANGHAI have been sold out.
<Officce-1>i want a ticket for SHANGHAI
<Officce-0>tickets for SHANGHAI have been sold out.
<Officce-0>i want a ticket for SHANGHAI
<Officce-4>sold a ticket for BEIJING
<Officce-4>BEIJING tickets still have 0
<Officce-4>i want a ticket for BEIJING
<Officce-3>tickets for BEIJING have been sold out.
<Officce-3>i want a ticket for BEIJING
<Officce-2>tickets for SHANGHAI have been sold out.
<Officce-2>i want a ticket for SHANGHAI
<Officce-1>tickets for SHANGHAI have been sold out.
<Officce-1>i want a ticket for BEIJING
<Officce-0>tickets for SHANGHAI have been sold out.
<Officce-0>i want a ticket for SHANGHAI
<Officce-4>tickets for BEIJING have been sold out.
<Officce-4>closed
<Officce-4>totally sold tickets:4,sell records:{BEIJING=2, SHANGHAI=2}
<Officce-3>tickets for BEIJING have been sold out.
<Officce-3>closed
<Officce-3>totally sold tickets:3,sell records:{TIANJING=2, SHANGHAI=1}
<Officce-2>tickets for SHANGHAI have been sold out.
<Officce-2>closed
<Officce-2>totally sold tickets:3,sell records:{BEIJING=2, TIANJING=1}
<Officce-1>tickets for BEIJING have been sold out.
<Officce-1>closed
<Officce-1>totally sold tickets:2,sell records:{SHANGHAI=2}
<Officce-0>tickets for SHANGHAI have been sold out.
<Officce-0>closed
<Officce-0>totally sold tickets:2,sell records:{BEIJING=1, TIANJING=1}


本文转自zhangjunhd51CTO博客，原文链接：http://blog.51cto.com/zhangjunhd/70767，如需转载请自行联系原作者
文章标签：
Java
数据库
关键词：
Java线程
Java多线程
线程售票
Java线程售票
Java售票
科技小先锋
目录
相关文章
凉凉心.
|
2月前
|
JSON 网络协议 安全
【Java】（10）进程与线程的关系、Tread类；讲解基本线程安全、网络编程内容；JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念，进程是处于运行过程中的程序，并且具有一定的独立功能，进程是系统进行资源分配和调度的一个独立单位一般而言，进程包含如下三个特征。独立性动态性并发性。
凉凉心.
160 1
凉凉心.
|
2月前
|
JSON 网络协议 安全
【Java基础】（1）进程与线程的关系、Tread类；讲解基本线程安全、网络编程内容；JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念，进程是处于运行过程中的程序，并且具有一定的独立功能，进程是系统进行资源分配和调度的一个独立单位一般而言，进程包含如下三个特征。独立性动态性并发性。
凉凉心.
178 1
小白学大数据
|
3月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
小白学大数据
217 1
Java 数据库 Spring
147 0
蓝易云
|
3月前
|
算法 Java
Java多线程编程：实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
蓝易云
232 16
艾伦~耶格尔
|
4月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程，涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案，助你掌握高性能并发编程技巧，应对多线程开发中的挑战。
艾伦~耶格尔
223 0
小白学大数据
|
4月前
|
数据采集 存储 前端开发
Java爬虫性能优化：多线程抓取JSP动态数据实践
Java爬虫性能优化：多线程抓取JSP动态数据实践
小白学大数据
153 0
欲揽西江月
|
5月前
|
Java API 调度
从阻塞到畅通：Java虚拟线程开启并发新纪元
从阻塞到畅通：Java虚拟线程开启并发新纪元
欲揽西江月
356 83
AI小云
|
5月前
|
安全 算法 Java
Java 多线程：线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术，涵盖线程的创建与启动、线程安全问题及其解决方案，包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法，帮助开发者提升程序性能与稳定性。
AI小云
203 0
东方睿赢
|
存储 监控 Java
Java多线程优化：提高线程池性能的技巧与实践
Java多线程优化：提高线程池性能的技巧与实践
东方睿赢
515 1

热门文章

最新文章

  • 1
    百宝箱开放平台 ✖️ Java SDK
  • 2
    【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
  • 3
    Java 设计模式之策略模式：灵活切换算法的艺术
  • 4
    Java 设计模式之状态模式：让对象的行为随状态优雅变化
  • 5
    java零基础学习者入门课程
  • 6
    Java 设计模式之观察者模式：构建松耦合的事件响应系统
  • 7
    Java 设计模式之责任链模式：优雅处理请求的艺术
  • 8
    Python threading模块：多线程编程的实战指南
  • 9
    【JUC】（1）带你重新认识进程与线程！！让你深层次了解线程运行的睡眠与打断！！
  • 10
    JUC系列之《CountDownLatch：同步多线程的精准发令枪 》
  • 1
    如何在Python中执行线程定时器
    270
  • 2
    局域网行为监控软件 C# 多线程数据包捕获算法：基于 KMP 模式匹配的内容分析优化方案探索
    178
  • 3
    华为仓颉语言初识：并发编程之线程的基本使用
    242
  • 4
    Netty源码—3.Reactor线程模型二
    128
  • 5
    Netty源码—2.Reactor线程模型一
    166
  • 6
    使用 Uber automaxprocs 正确设置 Go 程序线程数
    324
  • 7
    Arthas thread（查看当前JVM的线程堆栈信息）
    1196
  • 8
    【高薪程序员必看】万字长文拆解Java并发编程！(9-2)：并发工具-线程池
    255
  • 9
    并发设计模式实战系列(4)：线程池
    453
  • 10
    CentOS如何使用Pthread线程库
    180

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0
    • 下一篇
    阿里云负载均衡收费标准：ALB、NLB和CLB价格，包括LCU费用、实例费和公网带宽价格