import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class Main{

    public static void main(String[] args) {
        BlockingQueue<Integer> queueOut = new ArrayBlockingQueue<>(20);
        BlockingQueue<Integer> queueIn = new ArrayBlockingQueue<>(20);


        Empfaenger empfaenger= new Empfaenger(queueIn, queueOut);
        System.out.println("main,queuein: "+queueIn);
        System.out.println("main,queueout: "+queueOut);
        Sender sender=new Sender(queueIn,queueOut);

        while(true) {
            Thread t1 = new Thread(empfaenger.e1);
            //Thread t2 = new Thread(sender.s1);
            t1.start();
            //t2.start();
        }
    }
}




import com.google.gson.Gson;

import java.util.concurrent.BlockingQueue;

public class Empfaenger{
    private BlockingQueue<Integer> queueIn;
    private BlockingQueue<Integer> queueOut;

    static private Gson gson=new Gson();

    public Empfaenger(BlockingQueue<Integer> queueIn, BlockingQueue<Integer> queueOut) {
        this.queueIn=queueIn;
        this.queueOut=queueOut;
    }
    public Runnable e1 =new Runnable(){
        @Override
        public void run() {
            try{
                queueOut.offer(readConsole());
                //readFile();
                //readTCP();
                //readUDP();
                System.out.println("empf,queuein: "+queueIn);
                System.out.println("empf,queueout: "+queueOut);
            }catch(Exception exp){exp.printStackTrace();}
        }};

    private int readConsole() {
        System.out.println("zahl: ");
        int nachricht= scan.nextInt();
        return modify(nachricht);
    }

    private void readFile() {
    }

    private void readTCP() {
    }

    private void readUDP() {
    }


    private int modify(int a){
        return a++;
    }

    public BlockingQueue<Integer>getqueuein(){
        return queueIn;
    }
}


import java.util.concurrent.BlockingQueue;

public class Sender {
    public Sender(BlockingQueue queueOut) {
    }

    public Sender(BlockingQueue<Integer> queueIn, BlockingQueue<Integer> queueOut) {

    }

    public void write(){
        System.out.println("written text");

    }
}