Thread + Sync

public class Teste1 extends Thread {

	String valor;

	Teste2 produtora;
	BlockingQueue<String> workRequestList;
	Map<String, String> workersList;

	public Teste1(Teste2 produtora) {
		this.produtora = produtora;
		this.workRequestList = this.produtora.workRequestList;
		this.workersList = this.produtora.workersList;
	}

	public void run() {
		while (true) {
			try {
				this.valor = this.workRequestList.take();
				System.out.println("RECEBI VALOR: ");
				if (!this.workersList.isEmpty()) {
					System.out.println("RECEBI VALORES: ");
					System.out.print(valor);
					System.out.print(this.workersList.get(valor));
				} 
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

}

public class Teste2 {

	BlockingQueue<String> workRequestList;
	Map<String, String> workersList;
	Teste1 cons;
	
	public Teste2() {
		this.workRequestList = new LinkedBlockingQueue<String>();
		this.workersList = Collections.synchronizedMap(new LinkedHashMap<String, String>());
		this.cons = new Teste1(this);
		this.cons.start();
	}
	
	public static void main (String[] args) {
		Teste2 prod = new Teste2();
		try {
			prod.workRequestList.put("WORKER0001");
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		try {
			System.out.println("ESPERA");
			Thread.sleep(5000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		prod.workersList.put("WORKER0001", "787878");
	}
}