java线程聊天室(阻塞队列实现)

package com.block.stu3.entity; import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.BlockingQueue; public class UserEntity { String userName; private BlockingQueue<MessageEntity> msgQueue = new LinkedBlockingDeque<MessageEntity>(); public UserEntity() { } public UserEntity(String userName) { this.userName = userName; } public void put(MessageEntity msg) { try { msgQueue.put(msg); System.out.println(Thread.currentThread().getName() + "向用户:" + userName + ",[" + msgQueue.hashCode() + "]" + "成功发送消息 :" + msg.getMsgInfo()); } catch (InterruptedException e) { e.printStackTrace(); } } public MessageEntity takeMsg() { MessageEntity msg = null; try { System.out.println(">>>>" + userName + ",[" + msgQueue.hashCode() + "]" + " 准备从自己的队列中取消息......"); msg = msgQueue.take(); System.out.println(">>>>>>>>" + userName + ",["+ msgQueue.hashCode() + "]" + " 成功取出发给自己的消息: " + msg.getMsgInfo()); } catch (InterruptedException e) { e.printStackTrace(); } return msg; } public String getUserName() { return userName; } public void setUserName(String userName) { this.userName = userName; } }