java 多线程交通信号灯模拟过程详解

这学期我们java课程的课程设计项目----交通信号灯的线程设计

  • 实验目的:多线程设计,同步机制
  • 题意 设计一个交通信号灯类:
    • 变量:位置、颜色(红、黄、绿)、显示时间(秒)。
    • 方法:切换信号灯。
  • 创建并启动两个线程(东西向、南北向)同时运行。
  • 实验要求
    • 设计线程。
    • 设计路口信号灯示意图界面。
    • 进一步将每个方向的信号灯分成3种车道灯:左转、直行和右转。
    • 根据车流量进行时间的模糊控制。

在课程设计的开始并没有仔细看老师的要求,只知道是交通信号灯。然后就开始各种找资料,百度,网上大量的关于红绿灯的设计都是参考张孝祥老师的教程,大概的设计方法是创建了三个类 lamp、road、lampcontrol。

然鹅......对.....然鹅又来了,在查了大概两天资料后,我又反过来看了一遍老师发的设计要求.....这这这.....,光控制灯就行了啊,不要车的啊,捂脸...

所以设计思路马上就变得清晰,根据张老师的做法,每个路口都有三个灯,分别为左转、直行、右转,所以一共有12盏灯。按照要求,右转灯为常亮灯,左转和直行灯才有红绿交替。在除去右转灯的八个灯里面,又可以分为四组可以两两匹配的灯,分别为东西左转南北(平行转垂直)、南北直行(垂直通行)、南北左转东西(垂直转平行)、东西直行(平行通行)。

于是我给这个12个灯编了个号:

emmm 大概就是这样,但是跟生活中的红绿灯不同,生活中的都是看对面路口的灯,我们这里是模拟嘛....就各个路口用各个路口的灯呗.....

大致解释一下,

1号灯为由南向西的左转灯,2号灯为由南向北的直行灯,3号灯为由南向东的右转灯。

4号灯为由东向北的右转灯,5号灯为由东向西的直行灯,6号灯为由东向南的左转灯。

7号灯为由北向西的右转灯,8号灯为由北向南的直行灯,9号灯为由北向东的左转灯。

10号灯为由西向北的左转灯,11号灯为由西向东的直行灯,12号灯为由西向南的右转灯。

然后根据匹配的原则,大概就是这么一张图:

我们就可以得到:

这四组信号灯。

到这里我们思路就很清晰了,我们可以分别为每一组信号灯开一个进程,然后使四个进程循环交替进行就实现了绿灯的转换。使用了程的同步技术。

当然,我们都已经开了四个进程了,为了锦上添花,我当然不介意再加个小车了hhhhhh

实验结果图:

源代码:

light类:

package traffic;
 public class light {
	int x,y;         //灯在画布上的位置
	boolean status;      //灯的状态
	public light(int x,int y,boolean islight) {
		this.x=x;
		this.y=y;
		this.status=islight;
	}
	public void setlight(boolean sta) {    //对外接口更改灯的状态
		this.status=sta;
	}
}

lamp类:

package traffic;
 public class lamp implements Runnable {
	light opposite, now;      //相互匹配的两个灯
	int greentime;         //绿灯亮的时间
	int name;            //编组
	boolean status;         //状态
	static Object lock = new Object();

	public lamp(light l0, light l2,int gt, boolean st, int name) {
		now = l0;
		opposite = l2;
		status = st;
		greentime = gt;
		this.name = name;
		lightstatues();
	}

	public void change() {
		this.status = !(this.status);
		lightstatues();
	}
	public void setgreentime(int time) {
		this.greentime=time;
	}
	public int getgreentime() {
		return this.greentime;
	}
	public void lightstatues() {
		opposite.setlight(status);
		now.setlight(status);
	}

	public void run() {
		while (true) {
			synchronized (lock) {        //使用synchronized实现进程间的互斥
				if (name == mainclass.panel.islight) {      //使用辅助变量实现进程按顺序循环
					//System.out.println("now is: "+name);
					change();
					mainclass.panel.repaint();
					try {
						Thread.sleep(greentime);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					lock.notifyAll();        //唤醒其他进程
					change();
					mainclass.panel.LampChange();
					mainclass.panel.repaint();
					try {
						lock.wait();
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				} else {
					try {
						lock.wait();      //挂起进程
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		}
	}
}

Mypanel类:

package traffic;

import java.awt.Color;
import java.awt.Graphics;
import java.util.ArrayList;
import java.util.Random;
import javax.swing.JPanel;
public class Mypanel extends JPanel {
	light l0,l2,l3,l4,l5,l6,l7,l8,l9,l10,l11,l12;   //十二个灯
	lamp lamp1,lamp2,lamp3,lamp4;           //四组信号灯
	static int islight;                //实现进程循环的辅助变量
	Random r=new Random();
	static public ArrayList<light> lightlist= new ArrayList<light>();  //使用list方便遍历每个灯
	static public ArrayList<car> carlist= new ArrayList<car>();          //方便遍历每个车
	public Mypanel() {
		// TODO Auto-generated constructor stub
		l0=addlist(l0, 212, 316, false);
		l2=addlist(l2, 242, 316, false);
		l3=addlist(l3, 272, 316, true);
		l4=addlist(l4, 316, 116, true);
		l5=addlist(l5, 316, 146, false);
		l6=addlist(l6, 316, 176, false);
		l7=addlist(l7,116 , 70, true);
		l8=addlist(l8, 146, 70, false);
		l9=addlist(l9, 176, 70, false);
		l10=addlist(l10, 70, 212, false);
		l11=addlist(l11, 70, 242, false);
		l12=addlist(l12, 70, 272, true
		lamp1=new lamp(l9,l0,2000,false,0);
		lamp2=new lamp(l11,l5,2000,false,1);
		lamp3=new lamp(l10,l6,2000,false,2);
		lamp4=new lamp(l8,l2,2000,false,3);
 		islight = 0 ;
		Thread t1=new Thread(lamp1);      //创建并启动线程
		Thread t2=new Thread(lamp2);
		Thread t3=new Thread(lamp3);
		Thread t4=new Thread(lamp4);
		t1.start();
		t2.start();
		t3.start();
		t4.start();
	}
	light addlist(light a,int x,int y,boolean sta) {
		a=new light(x,y,sta);
		lightlist.add(a);
		return a;
	}
	public void addcar() {          //生成小车
		int now,next;
		now=r.nextInt(4);
		next=r.nextInt(4);
		car testcar=null;
		while(now==next)
			next=r.nextInt(4);
		switch(now) {
		case 0:
			testcar=new car(now,next,l0,l2,l3);
			break;
		case 1:
			testcar=new car(now,next,l6,l5,l4);
			break;
		case 2:
			testcar=new car(now,next,l9,l8,l7);
			break;
		case 3:
			testcar=new car(now,next,l10,l11,l12);
			break;
		}
		carlist.add(testcar);
		Thread catt=new Thread(testcar);
		catt.start();
	}
	public void LampChange() {
		islight=(islight+1)%4;
	}
	public void paint(Graphics g) {
		super.paint(g);

		g.setColor(Color.darkGray);    //画路
		g.fillRect(0, 100, 400, 6);
		g.fillRect(0, 300, 400, 6);
		g.fillRect(100, 0, 6, 400);
		g.fillRect(300, 0, 6, 400);
		g.setColor(Color.gray);
		g.fillRect(0, 200, 400, 2);
		g.fillRect(200, 0, 2, 400);
		g.setColor(Color.blue);
		g.setColor(Color.black);     //画信号灯板
		g.fillRect(202,306, 100, 40);
		g.fillRect(306,106, 40, 100);
		g.fillRect(106,60, 100, 40);
		g.fillRect(60,202,40, 100);
		light temp;
		car buf;
		for(int i=0;i<carlist.size();i++) {   //画车
			buf=carlist.get(i);
			g.setColor(Color.BLUE);
			g.fillRect(buf.x, buf.y, 50, 50);
		}
		for(int i=0;i<lightlist.size();i++) {    //画灯
			temp=lightlist.get(i);
			if(temp.status)
				g.setColor(Color.green);
			else
				g.setColor(Color.RED);
			g.fillOval(temp.x, temp.y, 20, 20);
		}
	}
}

welcomepanel类:

package traffic;
import java.awt.Color;
import java.awt.Font;
import java.awt.Graphics;
import javax.swing.JPanel;
public class welcomepanel extends JPanel implements Runnable{  //开始界面
	int info = 0;
	Boolean isLive=true;
	public void paint(Graphics g) {
		super.paint(g);
		g.fillRect(0, 0, 420,450);
		g.setColor(Color.red);
		g.setFont(new Font("微软雅黑", Font.BOLD, 30));
		if (info % 2 == 0) {
			g.drawString("多线程红绿灯模拟", 80, 150);
		}
	}

	public void run() {
		// TODO Auto-generated method stub
		while (true) {
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			info++;
			this.repaint();
			if (isLive == false) {
				break;
			}
		}
	}
}

set类:

package traffic;
import java.awt.FlowLayout;
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JTextField;
public class set extends JFrame implements ActionListener {   //设置界面
  JLabel lab1,lab2,lab3,lab4;
  JTextField jtext1,jtext2,jtext3,jtext4;
  JPanel panel1,panel2,panel3,panel4;
  JButton jb1,jb2;
  int time1,time2,time3,time4;
	public set(){
  	lab1=new JLabel("南北左转东西:");
  	lab2=new JLabel("东西直行:");
  	lab3=new JLabel("东西左转南北:");
  	lab4=new JLabel("南北直行:");
  	time1=mainclass.panel.lamp1.getgreentime();
  	time2=mainclass.panel.lamp2.getgreentime();
  	time3=mainclass.panel.lamp3.getgreentime();
  	time4=mainclass.panel.lamp4.getgreentime();
  	jtext1=new JTextField(String.valueOf(time1));
  	jtext2=new JTextField(String.valueOf(time2));
  	jtext3=new JTextField(String.valueOf(time3));
  	jtext4=new JTextField(String.valueOf(time4));

  	jb1=new JButton("确定");
  	jb1.addActionListener(this);
  	jb2=new JButton("取消");
  	jb2.addActionListener(this);
  	this.setLayout(new GridLayout(5,2,10,5));
  	this.add(lab1);
  	this.add(jtext1);
  	this.add(lab2);
  	this.add(jtext2);
  	this.add(lab3);
  	this.add(jtext3);
  	this.add(lab4);
  	this.add(jtext4);
  	this.add(jb1);
  	this.add(jb2);
  	this.setLocationRelativeTo(null);
  	this.setSize(200, 200);
  	this.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);
  	this.setResizable(false);
    this.setVisible(true);
  }
  public void actionPerformed(ActionEvent e) {
  	if(e.getSource()==jb1) {

  		if(jtext1.getText().length()==0||jtext2.getText().length()==0||jtext3.getText().length()==0||jtext4.getText().length()==0)
  			JOptionPane.showMessageDialog(this, "请输入完整数据!", "错误", JOptionPane.INFORMATION_MESSAGE);
  		else {
  			mainclass.panel.lamp1.setgreentime(Integer.parseInt(jtext1.getText()));
  			mainclass.panel.lamp2.setgreentime(Integer.parseInt(jtext2.getText()));
  			mainclass.panel.lamp3.setgreentime(Integer.parseInt(jtext3.getText()));
  			mainclass.panel.lamp4.setgreentime(Integer.parseInt(jtext4.getText()));
  			this.dispose();
  		}
  	}else if(e.getSource()==jb2){
  		this.dispose();
  	}
  }
}

mainclass主类:

package traffic;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.JFrame;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JOptionPane;
public class mainclass extends JFrame implements ActionListener{
	static Mypanel panel;
	JMenuBar jmb;
	JMenu jm1, jm2;
	JMenuItem jmi1, jmi2,jmi3,jmi4;
	welcomepanel sp;
	mainclass(){
		this.setTitle("traffic lamp");
		this.setSize(420,450);
		this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		jmb=new JMenuBar();
		jm1=new JMenu("控制");
		jm2=new JMenu("设置");
		jmi1=new JMenuItem("开始模拟");
		jmi1.addActionListener(this);
		jmi2=new JMenuItem("退出模拟");
		jmi2.addActionListener(this);
		jmi3=new JMenuItem("随机生成小车");
		jmi3.addActionListener(this);
		jmi4=new JMenuItem("更改绿灯时间");
		jmi4.addActionListener(this);
		jm1.add(jmi1);
		jm1.add(jmi2);
		jm1.add(jmi3);
		jm2.add(jmi4);
		jmb.add(jm1);
		jmb.add(jm2);

		this.setJMenuBar(jmb);

		sp=new welcomepanel();
		Thread t=new Thread(sp);
		t.start();
		this.setContentPane(sp);

		this.setLocationRelativeTo(null);
		this.setResizable(false);
		this.setVisible(true);
	}

	public void actionPerformed(ActionEvent e) {
		if(e.getSource()==jmi1) {
			sp.isLive=false;
			this.remove(sp);
			panel = new Mypanel();
			this.setContentPane(panel);
			this.setVisible(true);
		}else if(e.getSource()==jmi2) {
			System.exit(0);
		}else if(e.getSource()==jmi3) {
			if(panel==null)
  			JOptionPane.showMessageDialog(this, "请开始模拟再生成小车", "错误", JOptionPane.INFORMATION_MESSAGE);
			else panel.addcar();
		}else if (e.getSource() == jmi4) {
			if(mainclass.panel==null)
  			JOptionPane.showMessageDialog(this, "请开始模拟再进行设置", "错误", JOptionPane.INFORMATION_MESSAGE);
			else new set();
			}
		}
	public static void main(String[] args) {
		new mainclass();
	}
}

多线程正确性测试:

我们在lamp类的run()方法中添加了一句控制台打印命令,每次进程运行时即会打印此进程的name成员

正确的打印结果应该为 0-1-2-3-4-0-1-2-3-4-.......-1-2-3-....

控制台的输出结果为:

符合预测结果,实验完成!

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

时间: 2019-07-02

java多线程之火车售票系统模拟实例

1.前言 为了学习多线程共享与通信,我们模拟一个火车售票系统,假设有10张火车票,三个窗口(也就是三个线程)同时进行售票. 2.非同步代码 package com.tl.skyLine.thread; /** * Created by tl on 17/3/6. */ public class SellTicket { public static void main(String[] args) { TicketWindow tw = new TicketWindow(); Thread t1

java多线程模拟抢红包功能

今天有朋友问我一道面试题,有5个人抢5个红包,可重复抢,用多线程程序实现,实现方式有多种,分享一下我的思路:应用了阻塞队列的特性. /** * Created by zhanglinqiang on 2016/6/23. */ public class MyTest { public static void main(String[] args) throws InterruptedException { LinkedBlockingQueue<LuckyMoney> luckyMoneys

JAVA多线程的使用场景与注意事项总结

前言 我曾经对自己的小弟说,如果你实在搞不清楚什么时候用HashMap,什么时候用ConcurrentHashMap,那么就用后者,你的代码bug会很少. 他问我:ConcurrentHashMap是什么? -.- 编程不是炫技.大多数情况下,怎么把代码写简单,才是能力. 多线程生来就是复杂的,也是容易出错的.一些难以理解的概念,要规避.本文不讲基础知识,因为你手里就有jdk的源码. 线程 Thread 第一类就是Thread类.大家都知道有两种实现方式.第一可以继承Thread覆盖它的run方

以银行取钱为例模拟Java多线程同步问题完整代码

简单了解下在操作系统中进程和线程的区别: 进程:每个进程都有独立的代码和数据空间(进程上下文),进程间的切换会有较大的开销,一个进程包含1--n个线程.(进程是资源分配的最小单位) 线程:同一类线程共享代码和数据空间,每个线程有独立的运行栈和程序计数器(PC),线程切换开销小.(线程是cpu调度的最小单位) 线程和进程一样分为五个阶段:创建.就绪.运行.阻塞.终止. 多进程是指操作系统能同时运行多个任务(程序). 多线程是指在同一程序中有多个顺序流在执行.首先存钱取钱的这个操作,应该是线程操作的

java多线程学习之死锁的模拟和避免(实例讲解)

1.死锁 死锁是这样一种情形:多个线程同时被阻塞,它们中的一个或者全部都在等待某个资源被释放.由于线程被无限期地阻塞,因此程序不可能正常终止. Java 死锁产生的四个必要条件: 1.互斥使用,即当资源被一个线程使用(占有)时,别的线程不能使用 2.不可抢占,资源请求者不能强制从资源占有者手中夺取资源,资源只能由资源占有者主动释放. 3.请求和保持,即当资源请求者在请求其他的资源的同时保持对原有资源的占有. 4.循环等待,即存在一个等待队列:P1占有P2的资源,P2占有P3的资源,P3占有P1的

Java常见面试题之多线程和高并发详解

volatile 对 volatile的理解 volatile 是一种轻量级的同步机制. 保证数据可见性 不保证原子性 禁止指令重排序 JMM JMM(Java 内存模型)是一种抽象的概念,描述了一组规则或规范,定义了程序中各个变量的访问方式. JVM运行程序的实体是线程,每个线程创建时 JVM 都会为其创建一个工作内存,是线程的私有数据区域.JMM中规定所有变量都存储在主内存,主内存是共享内存.线程对变量的操作在工作内存中进行,首先将变量从主内存拷贝到工作内存,操作完成后写会主内存.不同线程间

Java多线程编程小实例模拟停车场系统

下面分享的是一个Java多线程模拟停车场系统的小实例(Java的应用还是很广泛的,哈哈),具体代码如下: Park类 public class Park { boolean []park=new boolean[3]; public boolean equals() { return true; } } Car: public class Car { private String number; private int position=0; public Car(String number)

详解Java多线程处理List数据

实例1: 解决问题:如何让n个线程顺序遍历含有n个元素的List集合 import java.util.ArrayList; import java.util.List; import org.apache.commons.lang3.ArrayUtils; public class Test_4 { /** * 多线程处理list * * @param data 数据list * @param threadNum 线程数 */ public synchronized void handleLi

详解Java去除json数据中的null空值问题

1.描述 @JsonInclude(JsonInclude.Include.NON_NULL)标记是jackson包提供的json序列化方法,已经集成于Springboot2.0中,此方法的配置意在可以对实体json序列化的时候进行对应的数值处理. 2.使用 用注解的方式放在标记类或者属性 @JsonInclude(JsonInclude.Include.NON_NULL) public class User implements Serializable { private String us

详解Java虚拟机管理的内存运行时数据区域

详解Java虚拟机管理的内存运行时数据区域 概述 Java虚拟机在执行Java程序的过程中会把它所管理的内存划分为若干个不同数据区域.这些区域都有各自的用途,以及创建和销毁的时间,有的区域随着虚拟机进程的启动而存在,有些区域则是依赖用户线程的启动和结束而建立和销毁. 程序计数器 程序计数器是一块较小的内存空间,它可以看作是当前线程所执行的字节码的行号指示器.在虚拟机的概念模型里,字节码解释器工作时就是通过改变这个计数器的值来选取下一条需要执行的字节码指令,分支,循环,跳转,异常处理,线程恢复等基

详解Java编写并运行spark应用程序的方法

我们首先提出这样一个简单的需求: 现在要分析某网站的访问日志信息,统计来自不同IP的用户访问的次数,从而通过Geo信息来获得来访用户所在国家地区分布状况.这里我拿我网站的日志记录行示例,如下所示: 121.205.198.92 - - [21/Feb/2014:00:00:07 +0800] "GET /archives/417.html HTTP/1.1" 200 11465 "http://shiyanjun.cn/archives/417.html/" &qu

详解java 中Spring jsonp 跨域请求的实例

详解java 中Spring jsonp 跨域请求的实例 jsonp介绍 JSONP(JSON with Padding)是JSON的一种"使用模式",可用于解决主流浏览器的跨域数据访问的问题.由于同源策略,一般来说位于 server1.example.com 的网页无法与不是 server1.example.com的服务器沟通,而 HTML 的<script> 元素是一个例外.利用 <script> 元素的这个开放策略,网页可以得到从其他来源动态产生的 JSO

详解Java线程池和Executor原理的分析

详解Java线程池和Executor原理的分析 线程池作用与基本知识 在开始之前,我们先来讨论下"线程池"这个概念."线程池",顾名思义就是一个线程缓存.它是一个或者多个线程的集合,用户可以把需要执行的任务简单地扔给线程池,而不用过多的纠结与执行的细节.那么线程池有哪些作用?或者说与直接用Thread相比,有什么优势?我简单总结了以下几点: 减小线程创建和销毁带来的消耗 对于Java Thread的实现,我在前面的一篇blog中进行了分析.Java Thread与内

详解Java中HashSet和TreeSet的区别

详解Java中HashSet和TreeSet的区别 1. HashSet HashSet有以下特点: 不能保证元素的排列顺序,顺序有可能发生变化 不是同步的 集合元素可以是null,但只能放入一个null 当向HashSet集合中存入一个元素时,HashSet会调用该对象的hashCode()方法来得到该对象的hashCode值,然后根据 hashCode值来决定该对象在HashSet中存储位置. 简单的说,HashSet集合判断两个元素相等的标准是两个对象通过equals方法比较相等,并且两个

详解java各种集合的线程安全

线程安全 首先要明白线程的工作原理,jvm有一个main memory,而每个线程有自己的working memory,一个线程对一个variable进行操作时,都要在自己的working memory里面建立一个copy,操作完之后再写入main memory.多个线程同时操作同一个variable,就可能会出现不可预知的结果.根据上面的解释,很容易想出相应的scenario. 而用synchronized的关键是建立一个monitor,这个monitor可以是要修改的variable也可以其

详解Java中list,set,map的遍历与增强for循环

详解Java中list,set,map的遍历与增强for循环 Java集合类可分为三大块,分别是从Collection接口延伸出的List.Set和以键值对形式作存储的Map类型集合. 关于增强for循环,需要注意的是,使用增强for循环无法访问数组下标值,对于集合的遍历其内部采用的也是Iterator的相关方法.如果只做简单遍历读取,增强for循环确实减轻不少的代码量. 集合概念: 1.作用:用于存放对象 2.相当于一个容器,里面包含着一组对象,其中的每个对象作为集合的一个元素出现 3.jav

详解Java 本地接口 JNI 使用方法

详解Java 本地接口 JNI 使用方法 对于Java程序员来说,Java语言的好处和优点,我想不用我说了,大家自然会说出很多一套套的.但虽然我们作为java程序员,但我们不得不承认java语言也有一些它本身的缺点.比如在性能.和底层打交道方面都有它的缺点.所以java就提供了一些本地接口,他主要的作用就是提供一个标准的方式让java程序通过虚拟机与原生代码进行交互,这也就是我们平常常说的java本地接口(JNI--java native Interface).它使得在 Java 虚拟机 (VM