第四十八天作业

老郭

今天主要学习内容**

47.1 线程同步 内核模式 - 生产者与消费者问题 信号量 Semaphore
47.2 线程同步 内核模式 - 临界区 Lock关键字 锁对象使用需要注意的问题
47.3 线程同步 内核模式 - 临界区 Monitor类 死锁的产生 及 死锁的处理方式

今日作业

1. 请修改HTTP代理采集验证系统,使用信号量对并发资源进行控制

曜石头

Semaphore s = new Semaphore(10, 20);
Run() 的
if (proxyQueue.TryDequeue(out p)){
Task.Factory.StartNew(async (o) =>{
        s.WaitOne();
        try{xxx执行代码xxx}
        catch{xxx错误处理xxx}
        finally{
        s.Release()
        }       
},p)}
esle{
        s.Release()
        xxx释放资源xxxx
}

public void Stop() {
        for (int i = 0; i < 10; i++)
        {
                s.WaitOne();
        }
}

public void Continue(){
        s.Release(10);
}

鱼塘是我的

将HttpProxyVerify.cs下的event替换为

Semaphore sp = new Semaphore(25, 50);

Run() 的 Task.Factory.StartNew(async (o) =>{}内添加sp.WaitOne();
Run() 的 finally里的最后添加 s.Release();
Run() 的if (proxyQueue.TryDequeue(out p))内的else里释放资源sp.Dispose();

        public void Stop() {
            for (int i = 0; i < 25; i++)
            {
                sp.WaitOne();
            }
        }

        public void Continue()
        {
           sp.Release(25);
        }

qingshanlushui

取代上一课的event
Semaphore s = new Semaphore(10, 50);

Run() 的 Task.Factory.StartNew(async (o) =>{}里的=最前添加    s.WaitOne();
Run() 的 finally里的最后添加 s.Release();
Run() 在全部结束后，也就是 if (proxyQueue.TryDequeue(out p))的else里面释放资源  s.Dispose();

        public void Stop() {
            //events.Reset();//暂停
            for (int i = 0; i < 10; i++)
            {
                s.WaitOne();
            }
        }

        public void Continue()
        {
            //events.Set();//继续
            s.Release(10);
        }