出于学习目的，我正在使用 TCP 机制实现 UDP(以保证安全传输)。
我使用的Semaphore是二进制的，所以它的sem = new Semaphore(1);。
我使用这个信号量来控制我的 sendBuf 的入口，它是一个包含所有已发送但尚未确认的包的 List 。由于我有时会在收到 ACK 时从中删除包，因此我需要确保在另一个线程从中删除某些内容时不会使用一个线程进行迭代。
真正困扰我的是:
public void timeoutTask(long seqNum) {
System.out.println("Timeout for package with SeqNum " + seqNum
+ " happened.");
timeoutValue *= 2;
try {
System.out.println("Acquire? in timeouttask");
sem.acquire();
System.out.println("Acquired! in timeouttask");
} catch (InterruptedException e1) {
System.out.println("semaphore not acquired");
e1.printStackTrace();
}for (FCpacket packet : sendBuf) {
System.out.println("Iterating!");
if (packet.getSeqNum() == seqNum) {
System.out.println("Package for seqNum " + seqNum + " found!");
reSendData = packet.getSeqNumBytesAndData();
DatagramPacket reSendPacket = new DatagramPacket(reSendData,
reSendData.length, hostaddress, SERVER_PORT);
try {
clientSocket.send(reSendPacket);
System.out.println("Packet with seq " + seqNum
+ " send again");
packet.setTimestamp(0);
startTimer(packet);
new ReceiveHandler(reSendData, reSendData.length,
clientSocket, rcvData, UDP_PACKET_SIZE, this).run();
} catch (IOException e) {
System.out.println("Couldn't send package");
e.printStackTrace();
}
}
}
sem.release();
System.out.println("released! in timeouttask");
控制台输出给我以下内容:
Acquire? in timeouttask
Acquired! in timeouttask
Iterating!
Paket for seqNum 1 found!
Packet with seq 1 send again
因此它获取信号量，开始迭代，甚至发送包，所以现在它应该:再次迭代(“迭代!”)或释放信号量。上述情况都没有发生，只是卡住了。我不知道为什么 - 有什么想法吗？
最佳答案
如果ReceiveHandler是一个Thread，它应该被调用为
new ReceiveHandler(reSendData, reSendData.length, clientSocket, rcvData, UDP_PACKET_SIZE, this).start();
但如果它是一个Runnable，它应该被调用为
new Thread(new ReceiveHandler(reSendData, reSendData.length, clientSocket, rcvData, UDP_PACKET_SIZE, this)).start();
run() 不会在单独的线程中执行任务。
参见:What's the difference between Thread start() and Runnable run()
关于java - 卡在受信号量保护的交互中，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40720252/