Sincronización de productor y consumidor con hilos en Java | Operating systems, scripting, PowerShell and security

Hilos, Java

package productorconsumidor;

import static java.lang.Thread.sleep;

public class ProductorConsumidor {
   public static void main(String[] args) {
      Recurso recurso = new Recurso();
      Producir p1 = new Producir(recurso, 1);
      Consumir c1 = new Consumir(recurso, 1);
      p1.start(); 
      c1.start();
   }
}
class Recurso {
   private int contenido;
   private boolean available = false;
   public synchronized int get() {
      while (available == false) {
         try {
            wait();
         }
         catch (InterruptedException e) {
         }
      }
      available = false;
      notifyAll();
      return contenido;
   }
   public synchronized void put(int valor) {
      while (available == true) {
         try {
            wait();
         }
         catch (InterruptedException e) { 
         } 
      }
      contenido = valor;
      available = true;
      notifyAll();
   }
}

class Consumir extends Thread {
   private Recurso recursoc;
   private int number;
   public Consumir(Recurso recurso, int number) {
      recursoc = recurso;
      this.number = number;
   }
   public void run() {
      int value = 0;
         for (int i = 0; i < 10; i++) {
            value = recursoc.get();
            System.out.println("Consumir recurso" + this.number+ " valor: " + value);
         }
    }
}

class Producir extends Thread {
   private Recurso recursop;
   private int number;

   public Producir(Recurso recurso, int number) {
      recursop = recurso;
      this.number = number;
   }

   public void run() {
      for (int i = 0; i < 20; i++) {
         recursop.put(i);
         System.out.println("Producir recurso" + this.number + " valor: " + i);
         try {
            sleep((int)(Math.random() * 100));
         } catch (InterruptedException e) { }
      }
   }
}

package productorconsumidor;

import static java.lang.Thread.sleep;

public class ProductorConsumidor {

public static void main(String[] args) {

Recurso recurso = new Recurso();

Producir p1 = new Producir(recurso, 1);

Consumir c1 = new Consumir(recurso, 1);

p1.start();

c1.start();

}

class Recurso {

private int contenido;

private boolean available = false;

public synchronized int get() {

while (available == false) {

try {

wait();

}

catch (InterruptedException e) {

}

available = false;

notifyAll();

return contenido;

}

public synchronized void put(int valor) {

while (available == true) {

try {

wait();

}

catch (InterruptedException e) {

}

contenido = valor;

available = true;

notifyAll();

}

class Consumir extends Thread {

private Recurso recursoc;

private int number;

public Consumir(Recurso recurso, int number) {

recursoc = recurso;

this.number = number;

}

public void run() {

int value = 0;

for (int i = 0; i < 10; i++) {

value = recursoc.get();

System.out.println("Consumir recurso" + this.number+ " valor: " + value);

}

class Producir extends Thread {

private Recurso recursop;

private int number;

public Producir(Recurso recurso, int number) {

recursop = recurso;

this.number = number;

}

public void run() {

for (int i = 0; i < 20; i++) {

recursop.put(i);

System.out.println("Producir recurso" + this.number + " valor: " + i);

try {

sleep((int)(Math.random() * 100));

} catch (InterruptedException e) { }

}

package productorconsumidor;

import static java.lang.Thread.sleep;

public class ProductorConsumidor {
   public static void main(String[] args) {
      Recurso recurso = new Recurso();
      Producir p1 = new Producir(recurso, 1);
      Consumir c1 = new Consumir(recurso, 1);
      p1.start(); 
      c1.start();
   }
}
class Recurso {
   private int contenido;
   private boolean available = false;
   public synchronized int get() {
      while (available == false) {
         try {
            wait();
         }
         catch (InterruptedException e) {
         }
      }
      available = false;
      notifyAll();
      return contenido;
   }
   public synchronized void put(int valor) {
      while (available == true) {
         try {
            wait();
         }
         catch (InterruptedException e) { 
         } 
      }
      contenido = valor;
      available = true;
      notifyAll();
   }
}

class Consumir extends Thread {
   private Recurso recursoc;
   private int number;
   public Consumir(Recurso recurso, int number) {
      recursoc = recurso;
      this.number = number;
   }
   public void run() {
      int value = 0;
         for (int i = 0; i < 10; i++) {
            value = recursoc.get();
            System.out.println("Consumir recurso" + this.number+ " valor: " + value);
         }
    }
}

class Producir extends Thread {
   private Recurso recursop;
   private int number;

   public Producir(Recurso recurso, int number) {
      recursop = recurso;
      this.number = number;
   }

   public void run() {
      for (int i = 0; i < 20; i++) {
         recursop.put(i);
         System.out.println("Producir recurso" + this.number + " valor: " + i);
         try {
            sleep((int)(Math.random() * 100));
         } catch (InterruptedException e) { }
      }
   }
}

package productorconsumidor;

import static java.lang.Thread.sleep;

public class ProductorConsumidor {

public static void main(String[] args) {

Recurso recurso = new Recurso();

Producir p1 = new Producir(recurso, 1);

Consumir c1 = new Consumir(recurso, 1);

p1.start();

c1.start();

}

class Recurso {

private int contenido;

private boolean available = false;

public synchronized int get() {

while (available == false) {

try {

wait();

}

catch (InterruptedException e) {

}

available = false;

notifyAll();

return contenido;

}

public synchronized void put(int valor) {

while (available == true) {

try {

wait();

}

catch (InterruptedException e) {

}

contenido = valor;

available = true;

notifyAll();

}

class Consumir extends Thread {

private Recurso recursoc;

private int number;

public Consumir(Recurso recurso, int number) {

recursoc = recurso;

this.number = number;

}

public void run() {

int value = 0;

for (int i = 0; i < 10; i++) {

value = recursoc.get();

System.out.println("Consumir recurso" + this.number+ " valor: " + value);

}

class Producir extends Thread {

private Recurso recursop;

private int number;

public Producir(Recurso recurso, int number) {

recursop = recurso;

this.number = number;

}

public void run() {

for (int i = 0; i < 20; i++) {

recursop.put(i);

System.out.println("Producir recurso" + this.number + " valor: " + i);

try {

sleep((int)(Math.random() * 100));

} catch (InterruptedException e) { }

}

package productorconsumidor;

import static java.lang.Thread.sleep;

public class ProductorConsumidor {
   public static void main(String[] args) {
      Recurso recurso = new Recurso();
      Producir p1 = new Producir(recurso, 1);
      Consumir c1 = new Consumir(recurso, 1);
      p1.start(); 
      c1.start();
   }
}
class Recurso {
   private int contenido;
   private boolean available = false;
   public synchronized int get() {
      while (available == false) {
         try {
            wait();
         }
         catch (InterruptedException e) {
         }
      }
      available = false;
      notifyAll();
      return contenido;
   }
   public synchronized void put(int valor) {
      while (available == true) {
         try {
            wait();
         }
         catch (InterruptedException e) { 
         } 
      }
      contenido = valor;
      available = true;
      notifyAll();
   }
}

class Consumir extends Thread {
   private Recurso recursoc;
   private int number;
   public Consumir(Recurso recurso, int number) {
      recursoc = recurso;
      this.number = number;
   }
   public void run() {
      int value = 0;
         for (int i = 0; i < 10; i++) {
            value = recursoc.get();
            System.out.println("Consumir recurso" + this.number+ " valor: " + value);
         }
    }
}

class Producir extends Thread {
   private Recurso recursop;
   private int number;

   public Producir(Recurso recurso, int number) {
      recursop = recurso;
      this.number = number;
   }

   public void run() {
      for (int i = 0; i < 20; i++) {
         recursop.put(i);
         System.out.println("Producir recurso" + this.number + " valor: " + i);
         try {
            sleep((int)(Math.random() * 100));
         } catch (InterruptedException e) { }
      }
   }
}

package productorconsumidor;

import static java.lang.Thread.sleep;

public class ProductorConsumidor {

public static void main(String[] args) {

Recurso recurso = new Recurso();

Producir p1 = new Producir(recurso, 1);

Consumir c1 = new Consumir(recurso, 1);

p1.start();

c1.start();

}

class Recurso {

private int contenido;

private boolean available = false;

public synchronized int get() {

while (available == false) {

try {

wait();

}

catch (InterruptedException e) {

}

available = false;

notifyAll();

return contenido;

}

public synchronized void put(int valor) {

while (available == true) {

try {

wait();

}

catch (InterruptedException e) {

}

contenido = valor;

available = true;

notifyAll();

}

class Consumir extends Thread {

private Recurso recursoc;

private int number;

public Consumir(Recurso recurso, int number) {

recursoc = recurso;

this.number = number;

}

public void run() {

int value = 0;

for (int i = 0; i < 10; i++) {

value = recursoc.get();

System.out.println("Consumir recurso" + this.number+ " valor: " + value);

}

class Producir extends Thread {

private Recurso recursop;

private int number;

public Producir(Recurso recurso, int number) {

recursop = recurso;

this.number = number;

}

public void run() {

for (int i = 0; i < 20; i++) {

recursop.put(i);

System.out.println("Producir recurso" + this.number + " valor: " + i);

try {

sleep((int)(Math.random() * 100));

} catch (InterruptedException e) { }

}

Publicado el día 15 de febrero de 2021

CATEGORÍAS

Hilos, Java

ETIQUETAS

Curso, Java, Jesús Niño, Jesús Niño Camazón, ln, notify, System, System.out.println, Tor

Cookie	Duración	Descripción
cookielawinfo-checkbox-analytics	11 months	This cookie is set by GDPR Cookie Consent plugin. The cookie is used to store the user consent for the cookies in the category "Analytics".
cookielawinfo-checkbox-functional	11 months	The cookie is set by GDPR cookie consent to record the user consent for the cookies in the category "Functional".
cookielawinfo-checkbox-necessary	11 months	This cookie is set by GDPR Cookie Consent plugin. The cookies is used to store the user consent for the cookies in the category "Necessary".
cookielawinfo-checkbox-others	11 months	This cookie is set by GDPR Cookie Consent plugin. The cookie is used to store the user consent for the cookies in the category "Other.
cookielawinfo-checkbox-performance	11 months	This cookie is set by GDPR Cookie Consent plugin. The cookie is used to store the user consent for the cookies in the category "Performance".
viewed_cookie_policy	11 months	The cookie is set by the GDPR Cookie Consent plugin and is used to store whether or not user has consented to the use of cookies. It does not store any personal data.

Sincronización de productor y consumidor con hilos en Java (Java, Hilos)

CATEGORÍAS

ETIQUETAS

MÁS