package loimed; import java.io.*; public class Kirjutaja implements Runnable { PipedReader allikas; int viivitus; public Kirjutaja(PipedReader allikas, int viivitus) { this.allikas = allikas; this.viivitus = viivitus; } public void run() { BufferedReader br = new BufferedReader(allikas); try { String rida = br.readLine(); while (rida != null) { System.out.println("Saabus: " + rida); Thread.sleep(viivitus); rida = br.readLine(); } } catch (Exception ex) { ex.printStackTrace(); } System.out.println("Kirjutaja ots"); } }