Przykłady na synchronized

src/main/java/p04_watki/konta/v_wlasna_proba/Konto.java

@@ -24,7 +24,7 @@ class Konto {
 		return numer;
 	}
 
-	public int getSaldo() {
+	public synchronized int getSaldo() {
 		return saldo;
 	}
 	
@@ -32,24 +32,38 @@ class Konto {
 		return "Konto nr " + numer + ", saldo: " + saldo + ", wł.: " + wlasciciel;			
 	}
 	
-	public void wplata(int kwota) {
+	public synchronized void wplata(int kwota) {
 		if(kwota < 0) {
 			throw new IllegalArgumentException("Ujemna kwota " + kwota + " we wpłacie");
 		}
-		
 		saldo += kwota;
+        notify();
 	}
 
-	public void wyplata(int kwota) throws BrakSrodkow {
+	public synchronized void wyplata(int kwota) throws BrakSrodkow {
 		if(kwota < 0) {
 			throw new IllegalArgumentException("Ujemna kwota " + kwota + " w wypłacie");
 		}
 		if(kwota > saldo) {
-			throw new BrakSrodkow("Brak środków na koncie nr " + numer);
+			throw new BrakSrodkow("Brak środków na koncie nr " + numer);
 		}
 		
 		saldo -= kwota;
 	}
 
+    public synchronized void wyplataCzekaj(int kwota) throws BrakSrodkow {
+        if(kwota < 0) {
+            throw new IllegalArgumentException("Ujemna kwota " + kwota + " w wypłacie");
+        }
+        try {
+            while(kwota > saldo) {
+                wait();
+            }
+            saldo -= kwota;
+            notify();
+        } catch (InterruptedException e) {
+        }
+    }
+
 }
 

src/main/java/p04_watki/konta/v_wlasna_proba/Przeploty.java

@@ -9,7 +9,7 @@ class Przeploty {
 		final int KWOTA = 10;
 		
 		Osoba ala = new Osoba("Ala", "Kowalska", LocalDate.now());
-		Konto konto = new Konto(1, 1000_000, ala);		
+		Konto konto = new Konto(1, 1_000_000, ala);
 		System.out.println(konto);
 		
 		Thread wplacacz = new Thread(() -> {
@@ -22,6 +22,13 @@ class Przeploty {
 				for(int i = 0; i < N; i++) {
 					try {
 						konto.wyplata(KWOTA);
+
+                        // w razie gdyby nie bylo jednej metody,
+                        // to trzeba by synchronizować łącznie odczyt i zapis
+//                        synchronized (konto) {
+//                            int saldo = konto.getSaldo();
+//                            konto.setSaldo(salso + 100);
+//                        }
 					} catch (BrakSrodkow e) {
 						System.err.println(e.getMessage());
 					}
@@ -33,6 +40,9 @@ class Przeploty {
 		wyplacacz.start();
 
 		System.out.println("Czekam na zakończenie");
+
+        wplacacz.interrupt();
+
 		try {
 			wplacacz.join();
 			wyplacacz.join();

src/main/java/p04_watki/konta/v_wlasna_proba/WyplacanieZCzekaniem.java

+package p04_watki.konta.v_wlasna_proba;
+
+import java.io.IOException;
+
+class WyplacanieZCzekaniem {
+
+	static volatile boolean koniec = false;
+
+	public static void main(String[] args) {
+	   	 final Osoba ala = new Osoba("Ala", "Kowalska", "2001-01-01");
+	   	 final Konto konto = new Konto(1, 1700, ala);
+	   	 
+    	System.out.println("początek " + konto);
+
+    	Thread wplacacz = new Thread(new Runnable() {
+        	public void run() {
+            	while (!koniec) {
+                	konto.wplata(1000);
+               	 
+                	System.out.println("wpłacacz: wpłaciłem 1000, saldo = " + konto.getSaldo());
+                	try {
+                    	Thread.sleep(4000);
+                	} catch (InterruptedException e) {
+                	}
+            	}
+        	}
+    	});
+    	Thread wyplacacz = new Thread(new Runnable() {
+        	public void run() {
+            	while (!koniec) {
+                	try {
+                    	konto.wyplataCzekaj(100);
+                	} catch (BrakSrodkow e) {
+                    	System.err.println("BRAK ŚRODKÓW");
+                	}
+                	System.out.println("wypłacacz: wypłaciłem 100, saldo = " + konto.getSaldo());
+                	try {
+                    	Thread.sleep(200);
+                	} catch (InterruptedException e) {
+                	}
+            	}
+        	}
+    	});
+
+    	wplacacz.start();
+    	wyplacacz.start();
+
+    	System.out.println("Wątki wystartowały");
+    	System.out.println("Naciśnij enter aby zakończyć");
+    	try {
+        	System.in.read();
+    	} catch (IOException e1) {
+    	}
+	
+    	koniec = true;
+
+    	try {
+        	wplacacz.join();
+        	wyplacacz.join();
+    	} catch (InterruptedException e) {
+        	System.err.println("INTERRUPTED");
+    	}
+
+    	System.out.println("na końcu: " + konto);
+	}
+}