在 Java 中的线程之间访问对象

Question

我有一个扩展 websocket 的类。在这个类中，它调用了每秒返回一次消息的东西。在我的 onMessage 函数中，我进行了各种处理，我将数据放入每条消息的 Short 数组中（目前每秒一次）。我的问题是我想产生一个新线程来运行一个类来读取这个数组并将它每秒写入一个文件。如何为原始类中的变量生成一个具有获取/设置功能的新线程？这背后的原因是读取器线程需要在写入文件后清除数组中的某些元素。请注意，我希望读取和写入线程独立，因此可以更改速率而不会相互影响。

Answer 1

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