所以,我有两个线程。
线程1管理客户端连接。(只有一个客户端和一个服务器)
我称它为我的服务器线程。
线程2管理向客户端发送消息。我称之为我的消息处理器线程。
线程1负责定期向客户端发送心跳等任务。
在编程时,我假设套接字不是线程安全的,但是缓冲区是安全的,只要我对服务器线程和处理器线程使用单独的缓冲区,我就没问题。
我还假设"PrintWriter“类似于Java中的套接字缓冲区。
在这些假设下,我编写了这个函数来发送心跳:
public void sendHeartBeat(){
logger.info("Sending a hearbeat!");
PrintWriter printWriter=null;
try {
printWriter = new PrintWriter(clientSocket.getOutputStream());
} catch (IOException e) {
logger.info(e.toString());
}
if(printWriter!=null){
printWriter.print("HEARTBEAT#");
printWriter.flush();
}
}另一个线程,也就是“处理器”线程做了类似的事情:
printWriter=new PrintWriter(theServer.getClientSocket().getOutputStream());以这种方式,每当我希望发送心跳时,我都会创建一个新的“缓冲区”,并且我的消息永远不会被覆盖。
不幸的是,情况似乎并非如此。我从管道中得到一条消息,如下: dsgdsbHEARTBEAT#sdg
这会导致稍后的核心转储。
以下是我的问题:
1)套接字显然不是线程安全的,但是我从套接字获得的PrintWriters是线程安全的吗?或者它只是返回相同的PrintWriter?
2)什么类似于Java中的套接字缓冲区?我该如何思考这个问题呢?
3)如何使这些线程不写入套接字上的同一缓冲区?
发布于 2009-04-03 15:21:46
将多个PrintWriter放在同一个流中是一种糟糕的设计。实际上,您至少希望调用它们的对象是同步的(或线程受限的)。
但是,假设出于某种原因,您确实需要多个PrintWriter:
第一个问题:Writer没有使用this作为锁。默认情况下,PrintWriter和BufferedWriter都使用构造它们的Writer作为锁。这显然是完全错误的。它们应该使用Writer的锁,而不是Writer本身。这是一个很容易犯的错误,因为拥有Object的锁定功能会消除静态类型安全。因此,您需要使用套接字OutputStream (或其他公共对象)作为锁来构造PrintWriter。
其次,我们在PrintWriter中有缓冲。因此,当缓冲区结束时,一半被写入,另一半等待下一次写入。为了防止这种情况,要么外部锁定以组合print和flush,要么使用自动刷新并添加新的行字符。
所以,它并不是真正意义上的线程安全,但你可以破解它。或者你可以使用更好的设计。
发布于 2009-04-03 14:58:48
您需要一种方法来在线程之间使用相同的PrintWriter (t1.writer == t2.writer,而不仅仅是从相同的PrintWriter创建的OutputStream)。使用相同的PrintWriter,所有写入操作都是同步的。
https://stackoverflow.com/questions/714287
复制相似问题