IllegalMonitorStateException Java
IllegalMonitorStateException Java
我正在为大学做一些工作，我们必须在 Java 中开发一个监视器，使我们能够相互排斥和同步资源。这个监视器的大脑是一个用 Petri 网建模的系统，它为我们提供了进程之间的同步。
该监视器必须有一个用于阻塞进程（无法访问监视器）的队列和一个用于条件变量的队列（如果该进程未同步）。当线程被阻塞（被红绿灯）时，它们被保存在一个向量中，然后通过 FIFO 策略被唤醒。当一个线程即将退出你想要唤醒一个睡眠线程的监视器时，问题出现在一个 IllegalMonitorStateException 向量中（在 class SemaforoFIFO 的 Signal() 方法中，在 notify() 中）并且不知道为什么。我读了很多关于 wait () 和 notify () 的文章，但找不到解决方案。
我确定问题是我对主题和我的想法都不了解，但希望能让我理解这个问题并在将来为我服务。谢谢。
请原谅我的英语。我来自阿根廷，使用 Google 翻译器。再见
下面是代码：
Class Vehiculo: 初始化处理 Petri 网中拍摄不同转换的线程（与资源交互）。这些具有包含所有转换的数组。
Class Monitor:负责提供互斥和同步进程
Class procesadorPetri: 负责取你要拍摄的车辆的transition number，并验证这个拍摄的条件是否存在。如果条件不满足，线程应该休眠。否则拍摄照片并更新系统状态。
Class varCondicional: 负责提供进程的同步。
Class semaforoFIFO:负责提供监视器内的互斥
这是我在 运行 程序时得到的错误：
Exception in thread "Thread-0" java.lang.IllegalMonitorStateException
at java.lang.Object.notify(Native Method)
at Modelo.SemaforoFifo.Signal(SemaforoFifo.java:40)
at Modelo.VarCondicionales.RESUME(VarCondicionales.java:51)
at Modelo.Monitor.disparo(Monitor.java:51)
at Modelo.Vehiculos.run(Vehiculos.java:35)
Class 监控：
public class Monitor {
private Semaforo mutex;
private VarCondicionales cond;
private procesadorPetri p;
private Vector<Object> colaEspera;
public Monitor(procesadorPetri p){
colaEspera = new Vector<Object>();
mutex = new SemaforoFifo(1, colaEspera);
cond = new VarCondicionales(mutex);
this.p = p;
}
public void disparo(int t) {
mutex.Wait();
while( !p.verificar(t) )
{
cond.DELAY();
}
p.Disparo(t);
System.out.println("El hilo " + Thread.currentThread().getName() + " disparó " + p.getElNombreTransicion(t));
p.mostrarEstado();
System.out.println("La cola del monitor tiene " + colaEspera.size() + " hilos bloqueados");
System.out.println("La cola de la variable de condicion tiene " + cond.Size() + " hilos bloqueados");
cond.RESUME();
System.out.println();
}
}
Class 变量:
import java.util.Vector;
public class VarCondicionales {
private Semaforo mutex;
private Semaforo condicion;
private Vector<Object> colaBloqueados;
public VarCondicionales(Semaforo sem) {
mutex = sem;
colaBloqueados = new Vector<Object>();
condicion = new SemaforoFifo(0, colaBloqueados);
}
public void DELAY() {
mutex.Signal();
condicion.Wait();
mutex.Wait();
}
public void RESUME() {
if(colaBloqueados.size() > 0) {
condicion.Signal();
}
else
mutex.Signal();
}
public int Size(){
return colaBloqueados.size();
}
}
Class semaforoFIFO:
import java.util.Vector;
public class SemaforoFifo implements Semaforo {
private int val;
private Vector<Object> colaBloqueados;
public SemaforoFifo(int t, Vector<Object> cola){
val = t;
colaBloqueados = cola;
}
public synchronized void Wait() {
while(val == 0){
try {
colaBloqueados.add(Thread.currentThread());
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
val=0;
}
public synchronized void Signal() {
if(colaBloqueados.size() > 0){
colaBloqueados.firstElement().notify(); //despierto al primer hilo de la cola y
colaBloqueados.removeElementAt(0); // lo elimino de la cola
}
val=1;
}
}
Class 车辆：
package Modelo;
public class Vehiculos extends Thread{
Monitor monitor;
private int[] disparos;
public Vehiculos (Monitor m, int[] a){
monitor = m;
disparos = a;
}
public void run(){
while(true){
try{
for(int i=0; i<disparos.length ; i++){
monitor.disparo(disparos[i]);
sleep(100);
}
} catch(InterruptedException e){
e.printStackTrace();
}
}
}
public void getDisparos(){
for(int i=0; i<disparos.length;i++){
System.out.print(disparos[i] + " ");
}
}
}
Class procesadorPetri:
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
public class procesadorPetri {
private int[] m_estado;
private int[][] m_incidencia;
private String[] nombreTransiciones;
private String[] nombrePlazas;
private int n_transiciones;
private int n_plazas;
public procesadorPetri (String PatchIncidencia, String PatchEstado, String PatchNombres){
n_transiciones = 0;
n_plazas = 0;
getCaracteristicas(PatchIncidencia, PatchEstado);
m_incidencia = new int[n_plazas][n_transiciones];
m_estado = new int[n_plazas];
nombreTransiciones = new String[n_transiciones];
nombrePlazas = new String[n_plazas];
getMatrices(PatchIncidencia, PatchEstado, PatchNombres);
}
private void getMatrices(String patchIncidencia, String patchEstado, String patchNombres) {
try {
String[] aux;
String linea;
BufferedReader br1 = new BufferedReader(new FileReader(patchIncidencia));
for(int j=0, i=0; (linea = br1.readLine()) != null; i++ , j=0){
aux = linea.split(" ");
while(j<n_transiciones){
m_incidencia[i][j] = Integer.parseInt(aux[j]);
j++;
}
}
br1.close();
BufferedReader br2 = new BufferedReader(new FileReader(patchEstado));
linea = br2.readLine();
aux = linea.split(" ");
int i = 0;
while(i<n_plazas){
m_estado[i] = Integer.parseInt(aux[i]);
i++;
}
br2.close();
BufferedReader br3 = new BufferedReader(new FileReader(patchNombres));
linea = br3.readLine();
aux = linea.split(" ");
for(i=0 ; i<n_transiciones;i++){
nombreTransiciones[i] = aux[i];
}
linea = br3.readLine();
aux = linea.split(" ");
for(i=0 ; i<n_plazas;i++){
nombrePlazas[i] = aux[i];
}
br3.close();
}catch (Exception e){
System.out.println("Error al leer los archivos..");
e.printStackTrace();
}
mostrarIncidencia();
System.out.println();
mostrarEstado();
System.out.println();
System.out.println();
System.out.println("se termino de leer la matriz de incidencia..");
System.out.println("se termino de leer la matriz de estado..");
System.out.println("\n");
}
private void getCaracteristicas(String patchIncidencia, String patchEstado) {
String l;
String[] aux;
int bandera = 0;
try {
BufferedReader br1 = new BufferedReader(new FileReader(patchIncidencia));
while((l = br1.readLine()) != null){
n_plazas++;
if(l != null && bandera == 0){
aux = l.split(" ");
n_transiciones = aux.length;
bandera=1;
}
}
System.out.println("El sistema consta de: PLAZAS = " + n_plazas + " TRANSICIONES = " + n_transiciones);
br1.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public void mostrarIncidencia(){
System.out.println();
for(int i = 0; i<n_plazas ; i++){
for(int j = 0; j < n_transiciones ; j++){
System.out.printf( "%2d ", m_incidencia[i][j]);
}
System.out.println();
}
}
public void mostrarEstado(){
System.out.print( "[");
for(int i = 0 ; i < n_plazas ; i++ ){
System.out.printf( "%2d ", m_estado[i]);
}
System.out.println( "]");
}
public int getNumeroPlazas(){
return n_plazas;
}
public int getNumeroTransiciones(){
return n_transiciones;
}
public void Disparo(int t){
for(int i=0; i<n_plazas;i++){
m_estado[i] = m_estado[i] + m_incidencia[i][t];
}
//System.out.println("Se disparo la transicion " + getElNombreTransicion(t));
}
public String getElNombreTransicion(int t){
return nombreTransiciones[t];
}
public String getElNombrePlaza(int t){
return nombrePlazas[t];
}
public ArrayList<Integer> disparosDisponibles(){
ArrayList<Integer> lista = new ArrayList<Integer>();
boolean verificacion = true;
//System.out.print("Disparos disponibles: ");
for(int i=0; i<n_transiciones;i++){
for(int j =0; j< n_plazas && verificacion != false; j++ ){
if((m_estado[j] + m_incidencia[j][i]) < 0){
verificacion = false;
}
}
if(verificacion){
//System.out.print(getElNombreTransicion(i) + " ");
lista.add(i);
}else{
verificacion = true;
}
}
//System.out.println();
return lista;
}
public boolean verificar(int t){
ArrayList<Integer> disparosPosibles = disparosDisponibles();
if(disparosPosibles.size() == 0){
return false;
}
for(Integer i : disparosPosibles){
if(i.intValue() == t){
//System.out.println("true");
return true;
}
}
//System.out.println("false");
return false;
}
}
Class 主要：
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
public class Main {
public static void main(String[] args){
String PatchVehiculos = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Vehiculos.txt";
String PatchNombres = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Nombres.txt";
String PatchInicidencia = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Incidencia.txt";
String PatchEstado = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Estado.txt";
String linea;
String[] aux;
ArrayList<int[]> lista= new ArrayList<int[]>();
ArrayList<Vehiculos> hilos= new ArrayList<Vehiculos>();
procesadorPetri p = new procesadorPetri(PatchInicidencia,PatchEstado,PatchNombres);
Monitor m = new Monitor(p);
try {
BufferedReader br1 = new BufferedReader(new FileReader(PatchVehiculos));
for(int i=0 ; (linea = br1.readLine()) != null ; i++){
aux = linea.split(" ");
lista.add(new int[aux.length]);
for(int j = 0; j < aux.length ; j++){
for(int k = 0 ; k < p.getNumeroTransiciones() ; k++){
if(aux[j].equals(p.getElNombreTransicion(k))){
lista.get(i)[j] = k;
}
}
}
hilos.add(new Vehiculos(m, lista.get(i)));
}
br1.close();
for(int i=0; i<hilos.size(); i++){
hilos.get(i).start();
}
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
在您的 Signal 方法中，您对 Vector 中的第一个元素调用 notify。问题是由于同步方法，线程拥有当前 class 实例的监视器，而不是 Vector 中的元素。
Signal方法是effectively the same as...
public void Signal() {
synchronized (this) {
// ...
}
}
...因此尝试在不是 SemaforoFifo 当前实例的对象上调用 notify、notifyAll 或 wait 将导致异常被抛出。
我正在为大学做一些工作，我们必须在 Java 中开发一个监视器，使我们能够相互排斥和同步资源。这个监视器的大脑是一个用 Petri 网建模的系统，它为我们提供了进程之间的同步。 该监视器必须有一个用于阻塞进程（无法访问监视器）的队列和一个用于条件变量的队列（如果该进程未同步）。当线程被阻塞（被红绿灯）时，它们被保存在一个向量中，然后通过 FIFO 策略被唤醒。当一个线程即将退出你想要唤醒一个睡眠线程的监视器时，问题出现在一个 IllegalMonitorStateException 向量中（在 class SemaforoFIFO 的 Signal() 方法中，在 notify() 中）并且不知道为什么。我读了很多关于 wait () 和 notify () 的文章，但找不到解决方案。 我确定问题是我对主题和我的想法都不了解，但希望能让我理解这个问题并在将来为我服务。谢谢。
请原谅我的英语。我来自阿根廷，使用 Google 翻译器。再见
下面是代码：
Class Vehiculo: 初始化处理 Petri 网中拍摄不同转换的线程（与资源交互）。这些具有包含所有转换的数组。
Class Monitor:负责提供互斥和同步进程
Class procesadorPetri: 负责取你要拍摄的车辆的transition number，并验证这个拍摄的条件是否存在。如果条件不满足，线程应该休眠。否则拍摄照片并更新系统状态。
Class varCondicional: 负责提供进程的同步。
Class semaforoFIFO:负责提供监视器内的互斥
这是我在 运行 程序时得到的错误：
Exception in thread "Thread-0" java.lang.IllegalMonitorStateException
at java.lang.Object.notify(Native Method)
at Modelo.SemaforoFifo.Signal(SemaforoFifo.java:40)
at Modelo.VarCondicionales.RESUME(VarCondicionales.java:51)
at Modelo.Monitor.disparo(Monitor.java:51)
at Modelo.Vehiculos.run(Vehiculos.java:35)
Class 监控：
public class Monitor {
private Semaforo mutex;
private VarCondicionales cond;
private procesadorPetri p;
private Vector<Object> colaEspera;
public Monitor(procesadorPetri p){
colaEspera = new Vector<Object>();
mutex = new SemaforoFifo(1, colaEspera);
cond = new VarCondicionales(mutex);
this.p = p;
}
public void disparo(int t) {
mutex.Wait();
while( !p.verificar(t) )
{
cond.DELAY();
}
p.Disparo(t);
System.out.println("El hilo " + Thread.currentThread().getName() + " disparó " + p.getElNombreTransicion(t));
p.mostrarEstado();
System.out.println("La cola del monitor tiene " + colaEspera.size() + " hilos bloqueados");
System.out.println("La cola de la variable de condicion tiene " + cond.Size() + " hilos bloqueados");
cond.RESUME();
System.out.println();
}
}
Class 变量:
import java.util.Vector;
public class VarCondicionales {
private Semaforo mutex;
private Semaforo condicion;
private Vector<Object> colaBloqueados;
public VarCondicionales(Semaforo sem) {
mutex = sem;
colaBloqueados = new Vector<Object>();
condicion = new SemaforoFifo(0, colaBloqueados);
}
public void DELAY() {
mutex.Signal();
condicion.Wait();
mutex.Wait();
}
public void RESUME() {
if(colaBloqueados.size() > 0) {
condicion.Signal();
}
else
mutex.Signal();
}
public int Size(){
return colaBloqueados.size();
}
}
Class semaforoFIFO:
import java.util.Vector;
public class SemaforoFifo implements Semaforo {
private int val;
private Vector<Object> colaBloqueados;
public SemaforoFifo(int t, Vector<Object> cola){
val = t;
colaBloqueados = cola;
}
public synchronized void Wait() {
while(val == 0){
try {
colaBloqueados.add(Thread.currentThread());
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
val=0;
}
public synchronized void Signal() {
if(colaBloqueados.size() > 0){
colaBloqueados.firstElement().notify(); //despierto al primer hilo de la cola y
colaBloqueados.removeElementAt(0); // lo elimino de la cola
}
val=1;
}
}
Class 车辆：
package Modelo;
public class Vehiculos extends Thread{
Monitor monitor;
private int[] disparos;
public Vehiculos (Monitor m, int[] a){
monitor = m;
disparos = a;
}
public void run(){
while(true){
try{
for(int i=0; i<disparos.length ; i++){
monitor.disparo(disparos[i]);
sleep(100);
}
} catch(InterruptedException e){
e.printStackTrace();
}
}
}
public void getDisparos(){
for(int i=0; i<disparos.length;i++){
System.out.print(disparos[i] + " ");
}
}
}
Class procesadorPetri:
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
public class procesadorPetri {
private int[] m_estado;
private int[][] m_incidencia;
private String[] nombreTransiciones;
private String[] nombrePlazas;
private int n_transiciones;
private int n_plazas;
public procesadorPetri (String PatchIncidencia, String PatchEstado, String PatchNombres){
n_transiciones = 0;
n_plazas = 0;
getCaracteristicas(PatchIncidencia, PatchEstado);
m_incidencia = new int[n_plazas][n_transiciones];
m_estado = new int[n_plazas];
nombreTransiciones = new String[n_transiciones];
nombrePlazas = new String[n_plazas];
getMatrices(PatchIncidencia, PatchEstado, PatchNombres);
}
private void getMatrices(String patchIncidencia, String patchEstado, String patchNombres) {
try {
String[] aux;
String linea;
BufferedReader br1 = new BufferedReader(new FileReader(patchIncidencia));
for(int j=0, i=0; (linea = br1.readLine()) != null; i++ , j=0){
aux = linea.split(" ");
while(j<n_transiciones){
m_incidencia[i][j] = Integer.parseInt(aux[j]);
j++;
}
}
br1.close();
BufferedReader br2 = new BufferedReader(new FileReader(patchEstado));
linea = br2.readLine();
aux = linea.split(" ");
int i = 0;
while(i<n_plazas){
m_estado[i] = Integer.parseInt(aux[i]);
i++;
}
br2.close();
BufferedReader br3 = new BufferedReader(new FileReader(patchNombres));
linea = br3.readLine();
aux = linea.split(" ");
for(i=0 ; i<n_transiciones;i++){
nombreTransiciones[i] = aux[i];
}
linea = br3.readLine();
aux = linea.split(" ");
for(i=0 ; i<n_plazas;i++){
nombrePlazas[i] = aux[i];
}
br3.close();
}catch (Exception e){
System.out.println("Error al leer los archivos..");
e.printStackTrace();
}
mostrarIncidencia();
System.out.println();
mostrarEstado();
System.out.println();
System.out.println();
System.out.println("se termino de leer la matriz de incidencia..");
System.out.println("se termino de leer la matriz de estado..");
System.out.println("\n");
}
private void getCaracteristicas(String patchIncidencia, String patchEstado) {
String l;
String[] aux;
int bandera = 0;
try {
BufferedReader br1 = new BufferedReader(new FileReader(patchIncidencia));
while((l = br1.readLine()) != null){
n_plazas++;
if(l != null && bandera == 0){
aux = l.split(" ");
n_transiciones = aux.length;
bandera=1;
}
}
System.out.println("El sistema consta de: PLAZAS = " + n_plazas + " TRANSICIONES = " + n_transiciones);
br1.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public void mostrarIncidencia(){
System.out.println();
for(int i = 0; i<n_plazas ; i++){
for(int j = 0; j < n_transiciones ; j++){
System.out.printf( "%2d ", m_incidencia[i][j]);
}
System.out.println();
}
}
public void mostrarEstado(){
System.out.print( "[");
for(int i = 0 ; i < n_plazas ; i++ ){
System.out.printf( "%2d ", m_estado[i]);
}
System.out.println( "]");
}
public int getNumeroPlazas(){
return n_plazas;
}
public int getNumeroTransiciones(){
return n_transiciones;
}
public void Disparo(int t){
for(int i=0; i<n_plazas;i++){
m_estado[i] = m_estado[i] + m_incidencia[i][t];
}
//System.out.println("Se disparo la transicion " + getElNombreTransicion(t));
}
public String getElNombreTransicion(int t){
return nombreTransiciones[t];
}
public String getElNombrePlaza(int t){
return nombrePlazas[t];
}
public ArrayList<Integer> disparosDisponibles(){
ArrayList<Integer> lista = new ArrayList<Integer>();
boolean verificacion = true;
//System.out.print("Disparos disponibles: ");
for(int i=0; i<n_transiciones;i++){
for(int j =0; j< n_plazas && verificacion != false; j++ ){
if((m_estado[j] + m_incidencia[j][i]) < 0){
verificacion = false;
}
}
if(verificacion){
//System.out.print(getElNombreTransicion(i) + " ");
lista.add(i);
}else{
verificacion = true;
}
}
//System.out.println();
return lista;
}
public boolean verificar(int t){
ArrayList<Integer> disparosPosibles = disparosDisponibles();
if(disparosPosibles.size() == 0){
return false;
}
for(Integer i : disparosPosibles){
if(i.intValue() == t){
//System.out.println("true");
return true;
}
}
//System.out.println("false");
return false;
}
}
Class 主要：
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
public class Main {
public static void main(String[] args){
String PatchVehiculos = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Vehiculos.txt";
String PatchNombres = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Nombres.txt";
String PatchInicidencia = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Incidencia.txt";
String PatchEstado = "C:\Users\Gringo\Documents\Workspace Java\FINAL\src\Datos\Estado.txt";
String linea;
String[] aux;
ArrayList<int[]> lista= new ArrayList<int[]>();
ArrayList<Vehiculos> hilos= new ArrayList<Vehiculos>();
procesadorPetri p = new procesadorPetri(PatchInicidencia,PatchEstado,PatchNombres);
Monitor m = new Monitor(p);
try {
BufferedReader br1 = new BufferedReader(new FileReader(PatchVehiculos));
for(int i=0 ; (linea = br1.readLine()) != null ; i++){
aux = linea.split(" ");
lista.add(new int[aux.length]);
for(int j = 0; j < aux.length ; j++){
for(int k = 0 ; k < p.getNumeroTransiciones() ; k++){
if(aux[j].equals(p.getElNombreTransicion(k))){
lista.get(i)[j] = k;
}
}
}
hilos.add(new Vehiculos(m, lista.get(i)));
}
br1.close();
for(int i=0; i<hilos.size(); i++){
hilos.get(i).start();
}
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
在您的 Signal 方法中，您对 Vector 中的第一个元素调用 notify。问题是由于同步方法，线程拥有当前 class 实例的监视器，而不是 Vector 中的元素。
Signal方法是effectively the same as...
public void Signal() {
synchronized (this) {
// ...
}
}
...因此尝试在不是 SemaforoFifo 当前实例的对象上调用 notify、notifyAll 或 wait 将导致异常被抛出。