在Java中访问头之间的对象

Question

我有一个扩展websocket的类。在这个类中，它调用一些每秒返回一次消息的东西。在我的onMessage函数中，我做了各种处理，其中我将数据放入每个消息的Short数组中(目前每秒一次)。我的问题是我想生成一个新的线程，运行一个类来读取这个数组，并将其写入一个文件一次。我如何在原始类中生成一个具有get/set功能的新线程?这背后的原因是，一旦读线程写入文件，它需要清除数组中的一些元素。请注意，我想让读和写线程独立，这样可以在不影响彼此的情况下改变速率。

Answer 1

您可以使用传统的生产者-消费者模型:从onMessage函数写入BlockingQueue，并从将其内容写入文件的单独线程中读取它。