写优先的读者写者问题(Java实现)

2024-03-10 21:10

本文主要是介绍写优先的读者写者问题(Java实现),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

该题系吉林大学19级软件学院操作系统课设题之一

 

 

先输入初始时的写者读者情况,优先级顺序做了随机处理

 

代码如下

GUI:


import javax.swing.*;
import javax.swing.border.Border;
import javax.swing.text.BadLocationException;
import javax.swing.text.SimpleAttributeSet;
import javax.swing.text.StyleConstants;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.LinkedList;
import java.util.concurrent.Semaphore;public class ReadAndWrite extends JFrame {public static Semaphore rw = new Semaphore(1);public static Semaphore mutex = new Semaphore(1);public static Semaphore w = new Semaphore(1);public static Semaphore fresh = new Semaphore(1);public static int count = 0;public static LinkedList<String> Re = new LinkedList<String>();//读空间public static LinkedList<String> Wr = new LinkedList<String>();//写空间public static LinkedList<String> ing = new LinkedList<String>();//正在的状态private int reader = 0;//写者数量和编号记录private int writer = 0;//读者数量和编号记录//三个大的文本区域static JTextPane jTextPane1 = new JTextPane();//读static JTextPane jTextPane2 = new JTextPane();//文件static JTextPane jTextPane3 = new JTextPane();//写ReadAndWrite(int a, int b){super("写优先的读者写者问题");reader = a+1;writer = b+1;for(int i = 1;i<=a;i++)new Thread(new Read(i)).start();for(int i = 1;i<=b;i++)new Thread(new Write(i)).start();setBounds(400,300,600,500);JPanel jPanel1 = new JPanel(new BorderLayout());//读JPanel jPanel2 = new JPanel(new BorderLayout());//临界区JPanel jPanel3 = new JPanel(new BorderLayout());//写jPanel1.setBackground(Color.CYAN);jPanel2.setBackground(Color.PINK);jPanel3.setBackground(Color.CYAN);this.add(jPanel1,BorderLayout.WEST);this.add(jPanel2,BorderLayout.CENTER);this.add(jPanel3,BorderLayout.EAST);JLabel label1 = new JLabel("       读者       ");JLabel label2 = new JLabel("        临界区");JLabel label3 = new JLabel("       写者       ");label1.setFont(new Font("宋体",Font.BOLD,20));label2.setFont(new Font("宋体",Font.BOLD,20));label3.setFont(new Font("宋体",Font.BOLD,20));jPanel1.add(label1,BorderLayout.NORTH);jPanel2.add(label2,BorderLayout.NORTH);jPanel3.add(label3,BorderLayout.NORTH);jTextPane2.setLayout(new FlowLayout(FlowLayout.CENTER));//没起作用jTextPane1.setEditable(false);//禁止编辑jTextPane2.setEditable(false);jTextPane3.setEditable(false);//三个大的文本区域jTextPane1.setFont(new Font("宋体",Font.BOLD,16));jTextPane2.setFont(new Font("宋体",Font.BOLD,16));jTextPane3.setFont(new Font("宋体",Font.BOLD,16));jPanel1.add(new JScrollPane(jTextPane1),BorderLayout.CENTER);jPanel2.add(new JScrollPane(jTextPane2),BorderLayout.CENTER);jPanel3.add(new JScrollPane(jTextPane3),BorderLayout.CENTER);JButton jButton1 = new JButton("加入读者");JButton jButton2 = new JButton("加入写者");jButton1.addActionListener(new ActionListener() {@Overridepublic void actionPerformed(ActionEvent e) {new Thread(new Read(reader)).start();reader++;}});jButton2.addActionListener(new ActionListener() {@Overridepublic void actionPerformed(ActionEvent e) {new Thread(new Write(writer)).start();writer++;}});jPanel1.add(jButton1,BorderLayout.SOUTH);jPanel3.add(jButton2,BorderLayout.SOUTH);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setVisible(true);}public static void insert1(String str)//读模块的gui部分{SimpleAttributeSet set = new SimpleAttributeSet();StyleConstants.setUnderline(set, true);try{jTextPane1.getDocument().insertString(jTextPane1.getDocument().getLength(), str + "\n", set);}catch (BadLocationException e){e.printStackTrace();}}public static void insert2(String str)//被访问文件模块的gui部分{SimpleAttributeSet set = new SimpleAttributeSet();StyleConstants.setUnderline(set, true);try{jTextPane2.getDocument().insertString(jTextPane2.getDocument().getLength(), str + "\n", set);}catch (BadLocationException e){e.printStackTrace();}}public static void insert3(String str)//写模块的gui部分{SimpleAttributeSet set = new SimpleAttributeSet();StyleConstants.setUnderline(set, true);try{jTextPane3.getDocument().insertString(jTextPane3.getDocument().getLength(), str + "\n", set);}catch (BadLocationException e){e.printStackTrace();}}public static void refresh(){jTextPane1.setText(null);jTextPane2.setText(null);jTextPane3.setText(null);for(String a : Re){insert1("读者"+a);}for(String b : ing){insert2(b);}for(String c : Wr){insert3("写者"+c);}}public static void main(String[] args){int a = Integer.parseInt(JOptionPane.showInputDialog("请输入初始读者数量"));int b = Integer.parseInt(JOptionPane.showInputDialog("请输入初始写者数量"));new ReadAndWrite(a,b);
//        new Thread(new Read(1)).start();
//        new Thread(new Read(2)).start();
//        new Thread(new Read(3)).start();
//        new Thread(new Write(1)).start();
//        new Thread(new Write(2)).start();}
}

写者

import java.util.concurrent.Semaphore;import java.util.Random;public class Read extends Thread{private int num;Read(int num){this.num = num;}public void run() {try {synchronized(this){Random random = new Random();wait(random.nextInt(500));ReadAndWrite.insert1("读者"+num+"打算读文件");ReadAndWrite.Re.add(num+"打算读文件");ReadAndWrite.w.acquire();           //实现写有先ReadAndWrite.mutex.acquire();       //防止读者之间同步访问count,读者互斥访问countif(ReadAndWrite.count==0)ReadAndWrite.rw.acquire();      //实现读写互斥ReadAndWrite.count++;               //我只要有东西正在读你,你就不许给我写东西,实现多读者同步的关键ReadAndWrite.mutex.release();ReadAndWrite.w.release();//以下为读文件的阶段ReadAndWrite.insert2("读者"+num+"正在读文件");ReadAndWrite.ing.add("读者"+num+"正在读文件");wait(random.nextInt(5000)+1500);ReadAndWrite.insert2("读者"+num+"结束读文件");ReadAndWrite.insert1("读者"+num+"完成读文件");ReadAndWrite.ing.remove("读者"+num+"正在读文件");ReadAndWrite.Re.remove(num+"打算读文件");//以上为读文件的阶段wait(3000);ReadAndWrite.fresh.acquire();              //实现刷新页面时,线程的互斥ReadAndWrite.refresh();                    //刷新页面,通过队列的信息刷新页面ReadAndWrite.fresh.release();ReadAndWrite.mutex.acquire();ReadAndWrite.count--;                   //文件读完了,读完一个出来一个,count--了if(ReadAndWrite.count==0)ReadAndWrite.rw.release();ReadAndWrite.mutex.release();}} catch (InterruptedException e) {System.out.println("读者"+num+"出现错误!");e.printStackTrace();}}}

读者

import java.util.Random;public class Write extends Thread
{private int num;Write(int num){this.num = num;}public void run(){try{synchronized(this){Random random = new Random();wait(random.nextInt(500));ReadAndWrite.insert3("写者"+num+"打算写文件");ReadAndWrite.Wr.add(num+"打算写文件");ReadAndWrite.w.acquire();ReadAndWrite.rw.acquire();ReadAndWrite.insert2("写者"+num+"正在写文件");ReadAndWrite.ing.add("写者"+num+"正在写文件");wait(random.nextInt(10000)+3000);ReadAndWrite.insert2("写者"+num+"结束写文件");ReadAndWrite.insert3("写者"+num+"完成写文件");ReadAndWrite.ing.remove("写者"+num+"正在写文件");ReadAndWrite.Wr.remove(num+"打算写文件");wait(3000);ReadAndWrite.fresh.acquire();ReadAndWrite.refresh();//刷新页面,通过队列的信息刷新页面ReadAndWrite.fresh.release();ReadAndWrite.rw.release();ReadAndWrite.w.release();}} catch (InterruptedException e){System.out.println("写者"+num+"出现错误!");e.printStackTrace();}}
}

环境:IDEA

 

这篇关于写优先的读者写者问题(Java实现)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/795516

相关文章

Spring Boot集成/输出/日志级别控制/持久化开发实践

《SpringBoot集成/输出/日志级别控制/持久化开发实践》SpringBoot默认集成Logback,支持灵活日志级别配置(INFO/DEBUG等),输出包含时间戳、级别、类名等信息,并可通过... 目录一、日志概述1.1、Spring Boot日志简介1.2、日志框架与默认配置1.3、日志的核心作用

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

破茧 JDBC:MyBatis 在 Spring Boot 中的轻量实践指南

《破茧JDBC:MyBatis在SpringBoot中的轻量实践指南》MyBatis是持久层框架,简化JDBC开发,通过接口+XML/注解实现数据访问,动态代理生成实现类,支持增删改查及参数... 目录一、什么是 MyBATis二、 MyBatis 入门2.1、创建项目2.2、配置数据库连接字符串2.3、入

Springboot项目启动失败提示找不到dao类的解决

《Springboot项目启动失败提示找不到dao类的解决》SpringBoot启动失败,因ProductServiceImpl未正确注入ProductDao,原因:Dao未注册为Bean,解决:在启... 目录错误描述原因解决方法总结***************************APPLICA编

深度解析Spring Security 中的 SecurityFilterChain核心功能

《深度解析SpringSecurity中的SecurityFilterChain核心功能》SecurityFilterChain通过组件化配置、类型安全路径匹配、多链协同三大特性,重构了Spri... 目录Spring Security 中的SecurityFilterChain深度解析一、Security

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

Apache Ignite 与 Spring Boot 集成详细指南

《ApacheIgnite与SpringBoot集成详细指南》ApacheIgnite官方指南详解如何通过SpringBootStarter扩展实现自动配置,支持厚/轻客户端模式,简化Ign... 目录 一、背景:为什么需要这个集成? 二、两种集成方式(对应两种客户端模型) 三、方式一:自动配置 Thick

Python实现网格交易策略的过程

《Python实现网格交易策略的过程》本文讲解Python网格交易策略,利用ccxt获取加密货币数据及backtrader回测,通过设定网格节点,低买高卖获利,适合震荡行情,下面跟我一起看看我们的第一... 网格交易是一种经典的量化交易策略,其核心思想是在价格上下预设多个“网格”,当价格触发特定网格时执行买

解决pandas无法读取csv文件数据的问题

《解决pandas无法读取csv文件数据的问题》本文讲述作者用Pandas读取CSV文件时因参数设置不当导致数据错位,通过调整delimiter和on_bad_lines参数最终解决问题,并强调正确参... 目录一、前言二、问题复现1. 问题2. 通过 on_bad_lines=‘warn’ 跳过异常数据3