写优先的读者写者问题(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

相关文章

使用Java将各种数据写入Excel表格的操作示例

《使用Java将各种数据写入Excel表格的操作示例》在数据处理与管理领域,Excel凭借其强大的功能和广泛的应用,成为了数据存储与展示的重要工具,在Java开发过程中,常常需要将不同类型的数据,本文... 目录前言安装免费Java库1. 写入文本、或数值到 Excel单元格2. 写入数组到 Excel表格

Java并发编程之如何优雅关闭钩子Shutdown Hook

《Java并发编程之如何优雅关闭钩子ShutdownHook》这篇文章主要为大家详细介绍了Java如何实现优雅关闭钩子ShutdownHook,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 目录关闭钩子简介关闭钩子应用场景数据库连接实战演示使用关闭钩子的注意事项开源框架中的关闭钩子机制1.

Python中pywin32 常用窗口操作的实现

《Python中pywin32常用窗口操作的实现》本文主要介绍了Python中pywin32常用窗口操作的实现,pywin32主要的作用是供Python开发者快速调用WindowsAPI的一个... 目录获取窗口句柄获取最前端窗口句柄获取指定坐标处的窗口根据窗口的完整标题匹配获取句柄根据窗口的类别匹配获取句

Maven中引入 springboot 相关依赖的方式(最新推荐)

《Maven中引入springboot相关依赖的方式(最新推荐)》:本文主要介绍Maven中引入springboot相关依赖的方式(最新推荐),本文给大家介绍的非常详细,对大家的学习或工作具有... 目录Maven中引入 springboot 相关依赖的方式1. 不使用版本管理(不推荐)2、使用版本管理(推

Java 中的 @SneakyThrows 注解使用方法(简化异常处理的利与弊)

《Java中的@SneakyThrows注解使用方法(简化异常处理的利与弊)》为了简化异常处理,Lombok提供了一个强大的注解@SneakyThrows,本文将详细介绍@SneakyThro... 目录1. @SneakyThrows 简介 1.1 什么是 Lombok?2. @SneakyThrows

MyBatis模糊查询报错:ParserException: not supported.pos 问题解决

《MyBatis模糊查询报错:ParserException:notsupported.pos问题解决》本文主要介绍了MyBatis模糊查询报错:ParserException:notsuppo... 目录问题描述问题根源错误SQL解析逻辑深层原因分析三种解决方案方案一:使用CONCAT函数(推荐)方案二:

在 Spring Boot 中实现异常处理最佳实践

《在SpringBoot中实现异常处理最佳实践》本文介绍如何在SpringBoot中实现异常处理,涵盖核心概念、实现方法、与先前查询的集成、性能分析、常见问题和最佳实践,感兴趣的朋友一起看看吧... 目录一、Spring Boot 异常处理的背景与核心概念1.1 为什么需要异常处理?1.2 Spring B

Python位移操作和位运算的实现示例

《Python位移操作和位运算的实现示例》本文主要介绍了Python位移操作和位运算的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 位移操作1.1 左移操作 (<<)1.2 右移操作 (>>)注意事项:2. 位运算2.1

如何在 Spring Boot 中实现 FreeMarker 模板

《如何在SpringBoot中实现FreeMarker模板》FreeMarker是一种功能强大、轻量级的模板引擎,用于在Java应用中生成动态文本输出(如HTML、XML、邮件内容等),本文... 目录什么是 FreeMarker 模板?在 Spring Boot 中实现 FreeMarker 模板1. 环

Qt实现网络数据解析的方法总结

《Qt实现网络数据解析的方法总结》在Qt中解析网络数据通常涉及接收原始字节流,并将其转换为有意义的应用层数据,这篇文章为大家介绍了详细步骤和示例,感兴趣的小伙伴可以了解下... 目录1. 网络数据接收2. 缓冲区管理(处理粘包/拆包)3. 常见数据格式解析3.1 jsON解析3.2 XML解析3.3 自定义