ChannelOutputInt channelOutputInt;

    public Producer(ChannelOutputInt channelOutputInt) {
        this.channelOutputInt = channelOutputInt;
    }

    @Override
    public void run() {
        int counter=0;
        while(true){
            channelOutputInt.write(++counter);
        }
    }