首页 > 代码库 > 43_2013年11月22日 线程池 Socket（Thread Lock Process 摇奖 线程池ThreadPool）
43_2013年11月22日 线程池 Socket（Thread Lock Process 摇奖 线程池ThreadPool）
1》模拟线程池，生产者消费者问题
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;namespace Product{ class Program { static void Main(string[] args) { //创建一个池子 MyConncetion[] connectionArry =new MyConncetion[100]; //索引 int index = -1; //创建10个消费者 for (int i = 0; i < 100; i++) { //其中的一个消费者 Thread thread = new Thread(() => { while (true) { lock (connectionArry) { if (index >= 0) { connectionArry[index] = null; Console.WriteLine("消费一个产品:" + index); index--; } } Thread.Sleep(200); } }); thread.IsBackground = true; thread.Start(); } //创建5个生产者 for (int i = 0; i < 5; i++) { //其中的一个消费者 Thread thread = new Thread(() => { while (true) { //lock后面要跟一个引用类型的实例。 锁住同一个对象（引用地址）就互斥 lock (connectionArry)//lock(this) { if (index < 99) { connectionArry[index + 1] = new MyConncetion(); Console.WriteLine("生产一个产品:" + (index+1)); index++; } } Thread.Sleep(500); } }); thread.IsBackground = true; thread.Start(); } Console.ReadKey(); } } public class MyConncetion { }}
2.》摇奖代码
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;using System.Windows.Forms;namespace YaoJiangFrm{ public partial class MainFrm : Form { private List<Label> lbLisnt = new List<Label>(); private Thread threadStart; private bool isRuning = false; public MainFrm() { InitializeComponent(); //Control.CheckForIllegalCrossThreadCalls = false; } private void MainFrm_Load(object sender, EventArgs e) { for (int i = 0; i < 6; i++) { Label lb = new Label(); lb.Text = "0"; lb.AutoSize = true; lb.Location = new Point(50 * i + 50, 100); this.Controls.Add(lb); lbLisnt.Add(lb); } } private void btnStart_Click(object sender, EventArgs e) { isRuning = true; Thread thread = new Thread(() => { Random r = new Random(); //不停改变lb的值 while (isRuning) { foreach (var item in lbLisnt) { string str = r.Next(0, 10).ToString(); if (item.InvokeRequired) { item.Invoke(new Action<string>(s => { item.Text = s; }),str); } else { item.Text = str; } } Thread.Sleep(200); } }); thread.IsBackground = true; thread.Start(); threadStart = thread; } private void btnStop_Click(object sender, EventArgs e) { isRuning = false; //if(threadStart==null|| (!threadStart.IsAlive)) //{ // return; //} //threadStart.Abort(); } void timer1_Tick(object sender, EventArgs e) { Console.WriteLine("11"); } }}
3》Process
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Diagnostics;using System.Drawing;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;namespace WinFrmProcess{ public partial class MainFrm : Form { public MainFrm() { InitializeComponent(); } private void btnOutputAllProcessInfos_Click(object sender, EventArgs e) { var allProcess = Process.GetProcesses(); foreach (var item in allProcess) { //Console.WriteLine(item.ProcessName+" " + item.Id); //item.Kill(); } } private void btnOpenNotepad_Click(object sender, EventArgs e) { //Process.Start("notepad","kkk.txt"); //Process.Start("iexplore.exe", "www.itcast.cn"); //Process.Start(@"C:\Program Files\Microsoft SQL Server\MSSQL10_50.MSSQLSERVER\MSSQL\Binn\fdlauncher.exe", "-s MSSQL10_50.MSSQLSERVER"); Process.Start(@"G:\NetClass\黑马9期\2013年11月22日 线程池 Socket\代码\WinFrmProcess\MainParamters\bin\Debug\MainParamters.exe", "ssss 2 4 33"); } }}
4》线程池ThreadPool
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;namespace WaitCallBackQueue{ class Program { static void Main(string[] args) { //线程队列 Queue<WaitCallback> queue =new Queue<WaitCallback>(); //入队 queue.Enqueue(a => { Console.WriteLine("ssss"); }); //调用线程池的线程执行 ThreadPool.QueueUserWorkItem(a => { Console.WriteLine("ssss"); }); } }}
5》带参数的线程
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;namespace ThreadStartParamterDemo{ class Program { static void Main(string[] args) { //ParameterizedThreadStart Thread thread =new Thread((s) => { Console.WriteLine( s); }); thread.Start("sssssss"); Console.ReadKey(); } }}
6》线程池基础
using System;using System.Collections.Generic;using System.Diagnostics;using System.Linq;using System.Text;using System.Threading;namespace ThreadPoolDemo{ class Program { static void Main(string[] args) { //WaitCallback //线程池的线程本身都是 后台线程。 //线程池的线程优势：线程可以进行重用。 //线程池 vs 手动创建线程 //启动一个线程：开辟一个内存空间，1M内存,线程有可能占用部分的寄存器 //线程非常多的时候，操作系统的花费大量时间用在线程切换。 // //ThreadPool.QueueUserWorkItem(s => //{ // Console.WriteLine(s); //},"shit"); //Stopwatch sw =new Stopwatch(); //sw.Start(); //for (var i = 0; i < 100; i++) //{ // new Thread(() => // { // int i1 = 0; // //Console.WriteLine( ++i1); // i1++; // }).Start(); //} //sw.Stop(); //Console.WriteLine(sw.Elapsed.TotalSeconds); //sw.Restart(); //for (var i = 0; i < 100; i++) //{ // ThreadPool.QueueUserWorkItem((s) => // { // int i1 = 0; // //Console.WriteLine(++i1); // Console.WriteLine(Thread.CurrentThread.ManagedThreadId); // i1++; // }); //} //sw.Stop(); //Console.WriteLine(sw.Elapsed.TotalSeconds); //获取线程池最大的线程数据 int numMax = 0; int runNumMax = 0; ThreadPool.GetMaxThreads(out numMax,out runNumMax); Console.WriteLine(numMax+ " " + runNumMax); //ThreadPool.GetMinThreads(); Console.ReadKey(); } }}
7》异步调用委托
using System;using System.Collections.Generic;using System.Linq;using System.Runtime.Remoting.Messaging;using System.Text;using System.Threading;using System.Threading.Tasks;namespace AsynDel{ class Program { static void Main(string[] args) { Console.WriteLine(" Main Thread:"+Thread.CurrentThread.ManagedThreadId); Func<int, int, string> delFunc = (a, b) => { Console.WriteLine(" Delegate Thread:" + Thread.CurrentThread.ManagedThreadId); Thread.Sleep(20000); return (a + b).ToString(); }; //string str = delFunc(3, 4); //异步调用委托 //delFunc.BeginInvoke(3, 4, null, null); //内部原理就是：使用了一个线程池的线程去执行了委托指向的方法。 #region 异步委托 简单方式 ////拿到异步委托的结果 //IAsyncResult result = delFunc.BeginInvoke(3, 4, null, null); ////if (result.IsCompleted) ////{ ////} ////EndoInvoke方法会阻塞当前的线程，直到异步委托指向完成之后，才能继续往下执行。 //string str = delFunc.EndInvoke(result); //Console.WriteLine(str); #endregion #region 有回调函数的异步委托 //delFunc.BeginInvoke(5, 6, MyAsyncCallback, "123"); delFunc.BeginInvoke(5, 6, MyAsyncCallback, delFunc); #endregion Console.ReadKey(); } //回调函数：是异步委托方法执行完成之后，再来调 回调函数。 public static void MyAsyncCallback(IAsyncResult ar) { var del = (Func<int, int, string>)ar.AsyncState; string str = del.EndInvoke(ar); ////1、拿到异步委托执行的结果 //AsyncResult result = (AsyncResult)ar; //var del = (Func<int, int, string>)result.AsyncDelegate; //string returnValue = http://www.mamicode.com/del.EndInvoke(result);>//Console.WriteLine("返回值是："+returnValue); ////2、拿到给回调函数的参数。 //Console.WriteLine("传给异步回调函数的参数："+result.AsyncState); Console.WriteLine("回调函数的线程 的id是："+Thread.CurrentThread.ManagedThreadId); } }}
43_2013年11月22日 线程池 Socket（Thread Lock Process 摇奖 线程池ThreadPool）
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。