在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
static Queue q1=new Queue(); static int b=0; 在这里我定义了一个整形变量b和队列q1. 接下去就可以创建多线程代码了.如下: MyThread myc; Thread[] myt; myt=new Thread[10]; myc=new MyThread(); for(int i=0;i<10;++i) { myt[i]=new Thread(new ThreadStart(myc.DoFun)); // System.Console.WriteLine("<<{0}>>",myt[i].GetHashCode()); myt[i].Start(); Thread.Sleep(1000); } 你可能惊奇的发现这里使用了一个类实例myc.在起初的设计中我使用了MyThread数组,对于本例来说这没有什么关系,当线程要使用不同的操作时,那就要使用其他的类实例了. 以下是完整的代码: using System; using System.Threading; using System.Collections; namespace shareThread { class MyThread { static Queue q1=new Queue(); static int b=0; public void DoFun() { lock(this) { ++b; q1.Enqueue(b); } System.Console.WriteLine("B:{0}--------------",b); PrintValues( q1 ); } public static void PrintValues( IEnumerable myCollection ) { System.Collections.IEnumerator myEnumerator = myCollection.GetEnumerator(); while ( myEnumerator.MoveNext() ) Console.Write( "\t{0}", myEnumerator.Current ); Console.WriteLine(); } } /// <summary> /// Class1 的摘要说明。 /// </summary> class ClassMain { /// <summary> /// 应用程序的主入口点。 /// </summary> [STAThread] static void Main(string[] args) { MyThread myc; Thread[] myt; myt=new Thread[10]; myc=new MyThread(); for(int i=0;i<10;++i) { myt[i]=new Thread(new ThreadStart(myc.DoFun)); // System.Console.WriteLine("<<{0}>>",myt[i].GetHashCode()); myt[i].Start(); //线程运行 Thread.Sleep(1000);//主线程睡眠 } System.Console.Read();//等待完成,dos窗口不会马上关闭了. } } } |
请发表评论