当我使用多线程应用程序并拥有单例资源时。在这个单例中,当另一个线程转到时,不显示状态的变化。
public class WhoConnect
{
private ReaderWriterLockSlim userLock = new ReaderWriterLockSlim();
private const int timeout = 2000;
private List<User> users = new List<User>();
private WhoConnect() { }
public static WhoConnect Instance => instance ?? instance = new WhoConnect();
public List<User> Users
{
get
{
userLock.TryEnterReadLock(timeout);
try { return users; }
finally { userLock.ExitReadLock(); }
}
}
public void AddUser(string sessionId, string characterName, int characterID, int terminalId, string ip, string language)
{
userLock.TryEnterWriteLock(timeout);
try
{
users.Add(new User(sessionId, characterName, characterID, terminalId, ip, language));
Thread.Sleep(50000);
}
finally { userLock.ExitWriteLock(); }
}
}我第一次使用的地方是:
WhoConnect.Instance.AddUser(socketId, "haha", 44, 3, "xx", "pl");在另一个线程中:
var k = WhoConnect.Instance.Users;当获取用户时,我的writebloc是false,而不是true。
发布于 2020-02-26 15:12:01
一个问题是,您在使用TryEnterWriteLock()和TryEnterReadLock()时没有检查锁是否被实际获得。要解决这个问题,只需使用EnterWriteLock()和EnterReadLock()即可。
public List<User> Users
{
get
{
userLock.EnterReadLock()
try { return users; } // DON'T DO THIS!
finally { userLock.ExitReadLock(); }
}
} 如果你真的需要超时,你必须检查锁是否真的被获取了,但是当锁不能被及时获取时,你必须处理这种情况...所以我怀疑这对你的情况来说是不是一个好的解决方案。例如:
public List<User> Users
{
get
{
if(userLock.TryEnterReadLock(timeout))
{
try { return users; } // DON'T DO THIS!
finally { userLock.ExitReadLock(); }
}
else throw new Exception("Could not acquire lock");
}
} 我看到的另一个关键问题是,当简单地返回锁下的用户列表时,锁是相当无用的,因为用户列表上的活动是在调用用户属性的方法中完成的,但随后锁已经退出...此外,该列表可以用于写入而不是读取,因此读锁可能不正确。一种解决方案是从列表中返回元素的副本:
public User[] Users
{
get
{
userLock.EnterReadLock()
try { return users.ToArray(); }
finally { userLock.ExitReadLock(); }
}
} 最后,Hans Passant在他的评论中提到了一个有效的观点,即创建实例不是线程安全的。要么像proposed那样使用Lazy<T>,要么使用锁。
https://stackoverflow.com/questions/51124502
复制相似问题