Thread q = Thread.currentThread ();

public class App implements Runnable {

    public static Queue<Integer> que = new LinkedList<Integer>();

    public void run() {
        int t;
        synchronized (que) {
            Thread q = Thread.currentThread ();
            while (!que.isEmpty()) {
                t = que.remove();
                System.out.println(t+" "+q);
            }
        }
    }
   public static void main(String[] args) {
 ExecutorService exec = Executors.newFixedThreadPool(2);
        for (int i = 0; i < 2; i++) {
            exec.execute(new App());
        }
}

synchronized (que)