gpt4 book ai didi

java - 两个线程通过同步方法访问队列;一个可以严格优先于另一个吗?

转载 作者:太空宇宙 更新时间:2023-11-04 14:16:22 27 4
gpt4 key购买 nike

我正在尝试为我大学的网络制作一个聊天应用程序。它实际上是两个程序:一个用于服务器,另一个用于客户端。所有客户端消息都将发送到服务器,并在其前面添加发送者的名称和预期目标。服务器使用此信息将消息发送到目标。

我编写了一个程序,它用 4 个类来模拟服务器端:Model、MessageCentre、Receiver 和 Sender。

接收器在一个独立的线程上生成字符串并将它们添加到 MessageCentre 中的队列中,并具有随机超时。 Sender 检查队列是否为空,如果不为空,则“发送”消息(仅打印消息)。Model 类仅包含启动 Receiver 和 Sender 线程的 main 方法。

这是模拟的代码:

模型类->

package model;

public class Model {
public static void main(String[] args) {
Receiver receiver = new Receiver();
Sender sender = new Sender();
receiver.start();
sender.start();
}
}

消息中心类->

package model;

import java.util.LinkedList;
import java.util.Queue;

public class MessageCentre {
private static Queue<String> pendingMessages = new LinkedList<>();

public static synchronized boolean centreIsEmpty() {
return pendingMessages.isEmpty();
}

public static synchronized String readNextAndRemove() {
return pendingMessages.remove();
}

public static synchronized boolean addToQueue(String message) {
return pendingMessages.add(message);
}
}

接收器类->

package model;

import java.util.Random;

public class Receiver extends Thread {

private int instance;

public Receiver() {
instance = 0; //gets incremented after each message
}

@Override
public void run() {
while (true) {
boolean added = MessageCentre.addToQueue(getMessage());
if (!added) {
System.out.println("Message " + instance + " failed to send");
}
try {
//don't send for another 0 to 10 seconds
Thread.sleep(new Random().nextInt(10_000));
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
}

private String getMessage() {
int copyInstance = instance;
instance++;

return "Message " + copyInstance;
}
}

发送者类别->

package model;

public class Sender extends Thread {
@Override
public void run() {
while(true) {
if(!MessageCentre.centreIsEmpty()) {
System.out.println(MessageCentre.readNextAndRemove());
}
}
}
}

问题:如果将 Receiver 类的 getMessage() 方法替换为从套接字输入流接受消息的方法,是否有可能丢失某些消息?

将所有收到的消息写入队列至关重要,这样就不会丢失消息。这个模拟似乎运行良好,但我无法测试通过套接字接收大量消息的场景。

我担心可能发生的情况如下:

接收方获取消息并尝试将其写入队列。发送方拥有队列以读取和删除其中的项目,从而防止接收方写入最新消息。接收方终于有机会将当前消息写入队列,但同时有一条新消息进入套接字输入流,从而永远丢失。

这种情况可能发生吗?如果是,是否可以通过将Receiver的优先级设置为高于Sender来阻止?

最佳答案

a new message simultaneously enters the socket input stream to be lost forever

总是有可能的,但是除非您负载很重或者有不必要的大关键部分,否则不太可能出现大量丢弃的请求。由于您无法控制的因素,也会发生请求被丢弃的情况,因此您的系统无论如何都需要在面对这些情况时保持稳健。

使用a queue implementation from java.util.concurrent而不是在 LinkedList 上手动同步,代码的队列部分应该没问题。

关于java - 两个线程通过同步方法访问队列;一个可以严格优先于另一个吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27678839/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com