C#多线程模拟同时并发如何实现

发布网友 发布时间：2022-05-06 04:14

我来回答

共4个回答

热心网友 时间：2022-06-29 15:05

可参考以下这段代码！
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.IO;
namespace Server
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
Control.CheckForIllegalCrossThreadCalls = false;
}

private void btnStart_Click(object sender, EventArgs e)
{
IPAddress ip = IPAddress.Parse(txtServer.Text);

//网络断点 ip地址和端口号
IPEndPoint point = new IPEndPoint(ip, int.Parse(txtPort.Text));

//创建负责监听用的socket
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
//绑定网络断点
socket.Bind(point);
//监听 10 连接队列的长度
socket.Listen(10);
SetTxt("开始监听");

Thread th = new Thread(Listen);//开启监听的线程
th.IsBackground = true;
th.Start(socket);
}
catch (Exception ex)
{
SetTxt(ex.Message);
}
}

Dictionary<string, Socket> dic = new Dictionary<string, Socket>();
void Listen(object o)
{
//负责监听用的socket
Socket socket = o as Socket;
while (true)
{
try
{
//创建负责通信用的socket
Socket connSocket = socket.Accept();
//获取客户端ip和端口
string ipStr = connSocket.RemoteEndPoint.ToString();
SetTxt(ipStr + ":连接成功");

//填充下拉框
cboUsers.Items.Add(ipStr);
//
dic.Add(ipStr, connSocket);

//开启线程接收消息
Thread th = new Thread(RecMsg);
th.IsBackground = true;
th.Start(connSocket);
}
catch (Exception ex)
{
SetTxt(ex.Message);
}

}

}

void RecMsg(object o)
{
Socket connSocket = o as Socket;
byte[] buffer = new byte[1024 * 1024 * 5];
while (true)
{
try
{
//count实际收到的字节个数
int count = connSocket.Receive(buffer);
string ipStr = connSocket.RemoteEndPoint.ToString();
if (count == 0)
{
SetTxt(ipStr + ":断开连接");
connSocket.Shutdown(SocketShutdown.Both);
connSocket.Close();
break;
}
string msg = Encoding.UTF8.GetString(buffer, 0, count);

SetTxt(ipStr + ":" + msg);
}
catch (Exception ex)
{
SetTxt(ex.Message);
break;
}

}

}

void SetTxt(string t)
{
txtLog.AppendText(t + "\r\n");
}

//发送文字消息
private void btnSend_Click(object sender, EventArgs e)
{
if (cboUsers.SelectedIndex > -1)
{
string key = cboUsers.Text;
byte[] buffer = Encoding.UTF8.GetBytes(txtMsg.Text);

List<byte> list = new List<byte>();
list.Add(1); //协议 1 文字
list.AddRange(buffer);

dic[key].Send(list.ToArray());
}
else
{
MessageBox.Show("请选择客户端");
}
}

//选择路径
private void btnSelect_Click(object sender, EventArgs e)
{
OpenFileDialog ofd = new OpenFileDialog();
if (ofd.ShowDialog() == System.Windows.Forms.DialogResult.OK)
{
txtPath.Text = ofd.FileName;
}
}

//发送文件
private void btnSendFile_Click(object sender, EventArgs e)
{
if (cboUsers.SelectedIndex > -1)
{
string key = cboUsers.Text;
//dic[key]
//判断文件是否存在
if (txtPath.Text.Length > 0)
{
using (FileStream fs = new FileStream(txtPath.Text,FileMode.Open))
{
byte[] buffer = new byte[fs.Length];
fs.Read(buffer, 0, buffer.Length);

List<byte> list = new List<byte>();
list.Add(2 ); //协议 2 文件
list.AddRange(buffer);

dic[key].Send(list.ToArray());
}
}
else
{
MessageBox.Show("请选择文件");
}
}
else
{
MessageBox.Show("请选择客户端");
}
}

//震动
private void btnZD_Click(object sender, EventArgs e)
{
if (cboUsers.SelectedIndex > -1)
{
string key = cboUsers.Text;

byte[] buffer = new byte[1];
buffer[0] = 3; //协议 3 震动

dic[key].Send(buffer);
}
else
{
MessageBox.Show("请选择客户端");
}
}
}
}

热心网友 时间：2022-06-29 15:06

int num=100;
Thread[] th=new Thread[num];
for (int i = 0; i < num; i++)
{
NewThread n = new NewThread(DoWork);
th[i]=n;

}

for (int i = 0; i < num; i++)
{

th[i].Start();

}追问这样是不行的，这样做和直接放在上面的那个循环里面是没什么区别的

追答那你就不能这么写了，得用同步机制。
int num=100;
Thread[] th=new Thread[num];
System.Threading.AutoResetEvent wait=new System.Threading.AutoResetEvent(false);
for (int i = 0; i {
wait.WaitOne();
DoWork(obj);
});
th[i]=n;
th[i].Start();
}
Thread.Sleep(1000);
wait.Set();

热心网友 时间：2022-06-29 15:06

不可能真的全部都同时进行的。系统里也是在多个线程高速切换来分配CPU的占用时间

热心网友 时间：2022-06-29 15:07

你以为并发指的是同时执行？追问我们的头让我做这样一个并发的测试工具，他的要求就是等待所有线程建好之后，在同一时刻一起运行，我也是很纠结啊，一直没找到合理的解决方案