Java多线程之简单模拟售票功能

 更新时间:2021年04月25日 10:03:28   作者:乔 三石  
这篇文章主要介绍了Java多线程之简单模拟售票功能,文中有非常详细的代码示例,对正在学习java的小伙伴们有很好地帮助,需要的朋友可以参考下

一、创建

在这里插入图片描述

二、完整代码

package com.ql;

import lombok.SneakyThrows;
import okhttp3.Call;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

import java.io.IOException;

public class Mythread extends Thread {
    public Mythread(String name) {
        super(name);
    }

    @SneakyThrows
    @Override
    public void run() {
        for (; ; ) {
            //锁的状态是默认是打开状态
            //获取锁的状态
            int lockStatus = this.findLockStatus();
            if (lockStatus == 0) {
                //修改锁的状态 =>>锁定
                this.locked();
                //获取总票数
                int tickets = this.findTickets();
                //剩余票数
                int i = this.remainVotes();
                //判断票数
                if (tickets < 1) {
                    //已售卖完 跳出循环
                    break;
                } else {
                    //卖一张票
                    int remainVotes = this.saleOneTicket();
                    System.out.println(this.getName() + "当前的票数:" + tickets);
                    System.out.println(this.getName() + "售票后:" + remainVotes);
                    //  释放锁
                    this.unlock();
                }
            }
        }


    }

    /**
     * 剩余票数
     *
     * @return
     * @throws IOException
     */
    private int remainVotes() throws IOException, InterruptedException {
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url("http://localhost:8080/lock/remainVotes").build();
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();

        String string = response.body().string();
        int ticketsVote = Integer.parseInt(string);
        return ticketsVote;
    }

    /**
     * 释放锁
     */
    private void unlock() throws IOException {
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url("http://localhost:8080/lock/unlock").build();
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
    }

    /**
     * 卖票一张
     */
    private int saleOneTicket() throws IOException {
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url("http://localhost:8080/lock/saleOneTicket").build();
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
        String string = response.body().string();
        int remainVotes = Integer.parseInt(string);
        return remainVotes;
    }

    /**
     * 获取锁的状态
     */
    private int findLockStatus() throws IOException {
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url("http://localhost:8080/lock/findLock").build();
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
        String string = response.body().string();
        int lockStatus = Integer.parseInt(string);
        return lockStatus;
    }

    /**
     * 修改锁状态
     */
    private int locked() throws IOException {
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url("http://localhost:8080/lock/locked").build();
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
        String string = response.body().string();

        int lockStatus = Integer.parseInt(string);
        return lockStatus;
    }


    /**
     * 查看总票数
     *
     * @throws IOException
     */
    private int findTickets() throws IOException {
        OkHttpClient okHttpClient = new OkHttpClient();
        Request request = new Request.Builder().url("http://localhost:8080/lock/findTickets").build();
        Call call = okHttpClient.newCall(request);
        Response response = call.execute();
        String string = response.body().string();
        Integer tickets = Integer.parseInt(string);
        return tickets;
    }
}

package com.ql;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/lock")
public class ClientService {
    /**
     * 总票数
     */
    private static Integer tickets = 100;

    /**
     * 锁的状态 0:未锁   1:锁
     */
    private static Integer lockStatus = 0;

    /**
     * 卖票
     */
    @RequestMapping("/saleOneTicket")
    public Integer saleOneTicket() {
        return tickets = tickets - 1;
    }

    /**
     * 查看总票数
     */
    @RequestMapping("/findTickets")
    public Integer findTickets() {
        return tickets;
    }

    /**
     * 查看锁的状态
     */
    @RequestMapping("/findLock")
    public synchronized Integer findLock() {
        Integer lock=lockStatus;
        //改变锁状态,使线程串行执行
        this.locked();
        return lock;
    }

    /**
     * 改变锁状态
     */
    @RequestMapping("/locked")
    public synchronized int locked() {
        //更改锁的状态为1(上锁),避免多个线程同时获取锁的状态都为0(未上锁),从而导致线程安全问题
        lockStatus = 1;
        return lockStatus;
    }

    /**
     * 释放锁
     */
    @RequestMapping("/unlock")
    public synchronized int unlock() {
        return lockStatus = 0;
    }

    /**
     * 剩余票数
     *
     * @return
     */
    @RequestMapping("/remainVotes")
    public int remainVotes() {

        return tickets;
    }

}

三、流程图解析

在这里插入图片描述

到此这篇关于Java多线程之简单模拟售票功能的文章就介绍到这了,更多相关Java模拟售票功能内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • hashtable桶数通常会取一个素数分析

    hashtable桶数通常会取一个素数分析

    这篇文章主要介绍了hashtable桶数通常会取一个素数分析的相关资料,需要的朋友可以参考下
    2016-12-12
  • SpringBoot实现短信发送及手机验证码登录

    SpringBoot实现短信发送及手机验证码登录

    本文主要介绍了SpringBoot实现短信发送及手机验证码登录,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-07-07
  • IDEA如何撤销本地commit的代码

    IDEA如何撤销本地commit的代码

    这篇文章主要介绍了IDEA如何撤销本地commit的代码问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • 使用jdbcTemplate查询返回自定义对象集合代码示例

    使用jdbcTemplate查询返回自定义对象集合代码示例

    这篇文章主要介绍了使用jdbcTemplate查询返回自定义对象集合代码示例,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-02-02
  • Java基于socket编程相关知识解析

    Java基于socket编程相关知识解析

    这篇文章主要为大家详细解析了Java基于socket编程的相关知识,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-09-09
  • maven混淆打包的实现步骤

    maven混淆打包的实现步骤

    本文主要介绍了maven混淆打包的实现步骤,包含了Maven项目混淆、瘦身、打包exe这几个方面,具有一定的参考价值,感兴趣的可以了解一下
    2024-02-02
  • 从Hello World开始理解GraphQL背后处理及执行过程

    从Hello World开始理解GraphQL背后处理及执行过程

    这篇文章主要为大家介绍了从Hello World开始理解GraphQL背后处理过程示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-08-08
  • SpringBoot集成shiro,MyRealm中无法@Autowired注入Service的问题

    SpringBoot集成shiro,MyRealm中无法@Autowired注入Service的问题

    今天小编就为大家分享一篇关于SpringBoot集成shiro,MyRealm中无法@Autowired注入Service的问题,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2019-03-03
  • springBoot配置国产达梦数据库的示例详解

    springBoot配置国产达梦数据库的示例详解

    本文向大家介绍springBoot 配置国产达梦数据库的相关知识,文章结合示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-04-04
  • java 动态生成bean的案例

    java 动态生成bean的案例

    这篇文章主要介绍了java 动态生成bean的案例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-02-02

最新评论