消息队列

Queue通常与Thread配对执行, 保证消息按照顺序安全执行.

private Queue<byte[]> buffQueue = new ConcurrentLinkedQueue<>();

 class DemoThread extends Thread {
        @Override
        public void run() {
            try {
                while (true) {
                    if (!buffQueue.isEmpty()) {
                          sdk.feedTransCn(readBuffer, len);
                    }
            }cache{}
         }
}