using System.Collections.Generic; using System.Threading; namespace FYSTest { public partial class MainWindow { List<int> list = new List<int>(); private ReaderWriterLock _rwlock = new ReaderWriterLock(); public MainWindow() { //InitializeComponent(); Thread ThRead = new Thread(new ThreadStart(Read)); ThRead.IsBackground = true; Thread ThRead2 = new Thread(new ThreadStart(Read)); ThRead2.IsBackground = true; Thread ThWrite = new Thread(new ThreadStart(Write)); ThWrite.IsBackground = true; ThRead.Start(); ThRead2.Start(); ThWrite.Start(); } private void Read() { while (true) { //使用一个 System.Int32 超时值获取读线程锁。 _rwlock.AcquireReaderLock(100); try { if (list.Count > 0) { int result = list[list.Count - 1]; } } finally { //减少锁计数,释放锁 _rwlock.ReleaseReaderLock(); } } } int WriteCount = 0;//写次数 private void Write() { while (true) { //使用一个 System.Int32 超时值获取写线程锁。 _rwlock.AcquireWriterLock(100); try { list.Add(WriteCount++); } finally { //减少写线程锁上的锁计数,释放写锁 _rwlock.ReleaseWriterLock(); } } } } }
时间: 2024-10-12 03:56:37