一. 基础并行多线程结构
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Threading;
using System.Diagnostics;
using System.Collections.Concurrent;
using System.IO;
using System.Net;
using System.Text.RegularExpressions;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
namespace 多线程练习
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
//建立大类的变量，用来在小类之间传递参数
//用户登录SID
private string m_ssid;
//private string ssid_;//第二种写法
private string m_yzmpic;
private string m_yzmid;
private string m_yzmidl;
//角色ID
private string m_charid;
//循环次数
private string m_cycle;
//土地编号
private string m_landnum;
//用户名
private string m_username;
//密码
private string m_password;
//循环延时1，2，3
private int delay1=200;
private int delay2=1500;
//显示延时类
private void button1_Click(object sender, EventArgs e)
{
stopWatch.Start();//用来记录程序运行时间
try
{
//Parallel.Invoke(Run1,Run2,Run3,Run4,Run5,Run6);//跑6个，注意需要在下方添加至少6个子程序。
//Parallel.Invoke(Run1,Run2,Run3,Run4);//只跑两个线程
Parallel.Invoke(Run1);//只跑一个
}
catch (AggregateException aex)
{
foreach (var ex in aex.InnerExceptions)
{
MessageBox.Show(ex.Message);
}
}
stopWatch.Stop();
MessageBox.Show("循环完成，总时间" + stopWatch.ElapsedMilliseconds/3600000.0 + "小时");//显示程序运行时间
}
private Stopwatch stopWatch = new Stopwatch();
//加载界面时需要显示或进行的操作
private void Form1_Load_1(object sender, EventArgs e)
{
label14.Text = delay1.ToString();
label15.Text = delay1.ToString();
label16.Text = delay2.ToString();
}
//并行子线程，可添加至n个，注意子程序间操作要互相独立，防止冲突。
public void run1()
{
//需要执行的操作1
}
public void run2()
{
//需要执行的操作1或2
}
public void run3()
{
//需要执行的操作1或2或3
}
}
}
二. 标准多线程方法，控制并发线程数，带线程锁
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Threading;
using System.Diagnostics;
namespace WindowsFormsApplication2练习用
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
private Stopwatch stopWatch = new Stopwatch();
private void buttonmt_Click(object sender, EventArgs e)
{
stopWatch.Start();
int runCount = 0;//控制线程数变量
//防止界面卡死的新线程
new Thread(new ParameterizedThreadStart(delegate
{ //多线程循环
for (int i = 0; i < 10; i++)
{
while (true)
{ //线程数控制
if (runCount < 3)
{
break;
}
else
{
Thread.Sleep(2000);
continue;
}
}
runCount++;
//多线程循环开始
new Thread(new ParameterizedThreadStart(delegate
{ //线程内操作（空），与子线程调用界面显示方法
BeginInvoke(new EventHandler(delegate
{
listBox1.Items.Add("线程已完成");
}));
lock (this)
{
runCount--;
}
})).Start();
}
//MessageBox.Show("程序已完成");
stopWatch.Stop();
//Thread.Sleep(5000);
MessageBox.Show("循环完成，总时间" + stopWatch.ElapsedMilliseconds + "毫秒");
})).Start();
}
private void button1_Click(object sender, EventArgs e)
{
stopWatch.Start();
int runCount = 0;
int[] intArray = { 1, 2, 3,4,5,6,7,8,9,0 };
new Thread(new ParameterizedThreadStart(delegate
{ //多线程遍历
foreach (int i in intArray)
{
while (true)
{
if (runCount < 2)
{
break;
}
else
{
Thread.Sleep(2000);
continue;
}
}
runCount++;
new Thread(new ParameterizedThreadStart(delegate
{
BeginInvoke(new EventHandler(delegate
{
listBox1.Items.Add("线程已完成"+intArray[i]);
}));
lock (this)
{
runCount--;
}
})).Start();
}
stopWatch.Stop();
MessageBox.Show("循环完成，总时间" + stopWatch.ElapsedMilliseconds + "毫秒");
})).Start();
}
}
}
