次のオブジェクトがあります。
public class DataStructures {
public Map<String, User> registeredUser;
private ReadWriteLock readWriteLock;
public DataStructures() {
this.registeredUser = new ConcurrentHashMap<>();
readWriteLock = new ReentrantReadWriteLock(true);
}
public ReadWriteLock getReadWriteLock() {
return readWriteLock;
}
}
次のブロックがあります。
if(user != null && user.status()) {
String userNameList = "";
dataStructures.getReadWriteLock().readLock().lock();//ReentrantReadWriteLock
List<User> userList = new ArrayList<>(dataStructures.registeredUser.values());
//Will perform a sort on the userlist according their initial registration number
Collections.sort(userList, Comparator.comparing(User::getRegistrationId));
for (User tmpUser : userList) {
userNameList += tmpUser.getUsername() + " ";
}
connections.send(connectionId, "10 " + "7 " + userList.size() + " " + userNameList);
dataStructures.getReadWriteLock().readLock().unlock();//ReentrantReadWriteLock
}
ご覧のとおり、誰も何かを書き込もうとしていないときにスレッドがこのコードから読み取れるようにするために、このコードの一部をロックしました。
また、次のコードがあります。
dataStructures.getReadWriteLock().writeLock().lock();//ReentrantReadWriteLock
if(dataStructures.registeredUser.putIfAbsent(username, new User(username, password, dataStructures.registraionId)) == null) {
connections.send(connectionId, "10 " + "01");
dataStructures.registraionId++;
}
else
connections.send(connectionId, "11 " + "01");
dataStructures.getReadWriteLock().writeLock().unlock();//ReentrantReadWriteLock
さて、最初のコード ブロックが発生すると、2 番目のブロックは最初のブロックが完了するまで待機することを知っています。私の質問dataStructure
は、次のコード ブロックで、誰かが書き込むと同時にオブジェクトから読み取ることができるかどうかです。または、ReentrantReadWriteLock ロックについて言及していないにもかかわらず、彼から読んでください。
String username = seperate[1];
String password = seperate[2];
User user = dataStructures.registeredUser.get(username);
前もって感謝します!