zoukankan      html  css  js  c++  java
  • 常用开固定个数多线程的处理方法

     private void button3_Click(object sender, EventArgs e)
            {
                Thread tCreater = new Thread(new ThreadStart(Creater));
                tCreater.Start();
                Thread tC1 = new Thread(new ThreadStart(ConsumeBill));
                tC1.Name = "tc1";
                tC1.Start();
                Thread tC2 = new Thread(new ThreadStart(ConsumeBill));
                tC2.Name = "tc2";
                tC2.Start();
                Thread tC3 = new Thread(new ThreadStart(ConsumeBill));
                tC3.Name = "tc3";
                tC3.Start();        
            }
            DataTable dt = null;
            public static object syncObj = new object();
            public void Creater()
            {
                while (true)
                {
                    if (dt == null || dt.Rows.Count == 0)
                    {
                        Console.WriteLine("生产者线程进入");
                        Monitor.Enter(syncObj);                                    
                        Console.WriteLine("生产者开始生产产品");
                        RecCityComplexPayBillApplyBll bll = new RecCityComplexPayBillApplyBll();
                        dt = bll.TableBySearch();
                        Console.WriteLine("生产者线程通知消费者继续");
                        Monitor.Pulse(syncObj);
                        Console.WriteLine("生产者线程进等待");
                        Monitor.Wait(syncObj);
                        Monitor.Exit(syncObj);
                    }
                }
            }
            public static object syncConsume = new object();
            public void ConsumeBill()
            {
                while (true)
                {
                    if (dt != null && dt.Rows.Count > 0)
                    {
                        Monitor.Enter(syncConsume);
    
                        Console.WriteLine("消费者者线程进入:" + Thread.CurrentThread.Name);
                        if (dt != null && dt.Rows.Count > 0)
                        {
    
                            Console.WriteLine("消费者取出产品:" + Thread.CurrentThread.Name);
                            DataRow dr = dt.Rows[0];
                            RecCityComplexPayBillApplyInfo info = new RecCityComplexPayBillApplyInfo();
                            info.BaseImportByRow(dr);
                            dt.Rows.Remove(dr);
    
                            Console.WriteLine("消费者线程退出" + Thread.CurrentThread.Name);
    
    if(dt.Rows.Count>0)
    {
                     Monitor.Exit(syncConsume);
    //自行实现process处理先释放资源,然后再处理,一边其他线程能继续处理其他记录
       process(info);
       } else
    {
    //自行实现process处理,
    process(info);
    Monitor.Enter(syncObj);
                            //通知生产者线程
                                Console.WriteLine("消费者者线程通知生产者产品:" + Thread.CurrentThread.Name);
                                Monitor.Pulse(syncObj);

    //消费者独占消费资源并等待处理线程处理记录,以便所有线程都能处理完成(偶尔会出现处理未结束,生产者已经开始,但能最大限度的保证重复处理)
                       //所有消费者线程等待

                                Console.WriteLine(
    "消费者者线程等待生产者产生产品wait:" + Thread.CurrentThread.Name);
                                Monitor.Wait(syncObj);
                                Console.WriteLine(
    "消费者者线程开始执行:" + Thread.CurrentThread.Name);
                                Monitor.Exit(syncObj);
                       Monitor.Exit(syncConsume);
    }
    } else
    {
    //系统不会进到该出
     Monitor.Exit(syncConsume);
    }
    } }
  • 相关阅读:
    zend guard加密使用方法
    在网页中嵌入任意字体(特殊字体/自定义字体)的解决方案
    lamp一键安装包
    PHP错误“This file has expired”的解决方法
    php采集
    smarty建的mvc环境
    sql语句操作数据库重复数据
    古语:花繁柳密处拨得开,才是手段;风狂雨急时立的定,方显脚跟。
    获取日期的jquery.ui.datepicker
    el表达式简介
  • 原文地址:https://www.cnblogs.com/360qq/p/Thread.html
Copyright © 2011-2022 走看看