搜索
bottom↓
回复: 21

请教C#线程通信的问题

[复制链接]

出0入0汤圆

发表于 2020-7-30 01:15:27 | 显示全部楼层 |阅读模式
线程一:调用sendmessage(buffer); sendmessage中设置sendEvent.set();
线程二:if(sendEvent.waitone()){执行相关代码};
问题:sendmessage执行后,线程二中的代码不是每次都执行。不知道哪里出问题了。

阿莫论坛20周年了!感谢大家的支持与爱护!!

一只鸟敢站在脆弱的枝条上歇脚,它依仗的不是枝条不会断,而是自己有翅膀,会飞。

出0入8汤圆

发表于 2020-7-30 02:55:43 | 显示全部楼层
调用set之前有没有判断,线程2处于ready等状态呢?两个线程同步实际上需要一个握手的过程,目前你只提到了2等1的信号,其实2也有需要1等的时候,2会busy吗,是的话那也要同步。

出0入0汤圆

 楼主| 发表于 2020-7-30 06:46:05 来自手机 | 显示全部楼层
本帖最后由 zw_7627 于 2020-7-30 06:49 编辑
uindex 发表于 2020-7-30 02:55
调用set之前有没有判断,线程2处于ready等状态呢?两个线程同步实际上需要一个握手的过程,目前你只提到了2 ...


线程一在sendmessage后,有thread.sleep(),但调试发现,等多久线程二有时执行一次,有时一次都不执行。

出0入20汤圆

发表于 2020-7-30 09:28:18 | 显示全部楼层
线程2有while(true)吗?debug看一下线程2的状态就知道了,你这个看起来是线程2退出或者根本没有在执行,又或者说是2L说的在干其他的事情,miss掉了这个同步信号。

出0入0汤圆

发表于 2020-7-30 11:12:07 | 显示全部楼层
上代码                     

出0入16汤圆

发表于 2020-7-30 11:31:01 | 显示全部楼层
换别的通信方式玩?MSMQ?

出0入0汤圆

 楼主| 发表于 2020-7-30 21:03:12 | 显示全部楼层

问题是线程1有时不能进。。。
Thread rec_th = new Thread(new ThreadStart(线程1));
            rec_th.Priority = ThreadPriority.AboveNormal;
            rec_th.IsBackground = true;
            rec_th.Start();

Thread displayoriginaldata_th = new Thread(new ThreadStart(线程2));
            displayoriginaldata_th.Priority = ThreadPriority.BelowNormal;
            displayoriginaldata_th.IsBackground = true;
            displayoriginaldata_th.Start();

public void 线程1()
{
        byte buf;
          while(1)
        {
                   if (dataToSend.usSendEvent.WaitOne())
                {
                        object LockThis = new object();
                            lock (LockThis)
                            {
                                buf = bufTemp;
                                sendframe(buf);
                        }
                }
        }
}

byte bufTemp;

public void sendmessage(byte buffer)
{
        dataToSend.usSendEvent.Set();
        bufTemp = buffer;
}

public void 线程2()
{
        sendmessage(buf);
        Thread.Sleep(100);
        ...//do something
        sendmessage(buf);
        Thread.Sleep(100);
}

出0入8汤圆

发表于 2020-7-30 22:45:23 | 显示全部楼层
感觉是因为sendframe(buf);太耗时,注释掉先看看是不是如你所愿吧。

出0入0汤圆

 楼主| 发表于 2020-7-30 23:10:41 | 显示全部楼层
uindex 发表于 2020-7-30 22:45
感觉是因为sendframe(buf);太耗时,注释掉先看看是不是如你所愿吧。

注释了sendframe,线程一第一次进入,第二次没有进入。。。

出0入0汤圆

发表于 2020-7-31 07:43:12 | 显示全部楼层
zw_7627 发表于 2020-7-30 21:03
问题是线程1有时不能进。。。
Thread rec_th = new Thread(new ThreadStart(线程1));
            rec_th ...

不知道你详细代码。 你第一次WaitOne 进入了 有没有出来呢? 你这个里面的Lock ,呃,总觉得怪怪的,Lock 一个局部变量。。。。   而且线程通讯有问题,建议先注释掉线程的优先级设定。

出0入0汤圆

发表于 2020-7-31 08:40:00 | 显示全部楼层
去掉Lock试试

出0入0汤圆

发表于 2020-7-31 08:44:39 | 显示全部楼层
你可以监控一下,线程1停在哪条代码,是停在 if (dataToSend.usSendEvent.WaitOne())   还是停在lock (LockThis)

出0入8汤圆

发表于 2020-7-31 09:03:23 | 显示全部楼层
zw_7627 发表于 2020-7-30 23:10
注释了sendframe,线程一第一次进入,第二次没有进入。。。

哥们你贴出来的代码没问题:

using System;
using System.Threading;

namespace TestThread
{
    class Program
    {
        static AutoResetEvent usSendEvent = new AutoResetEvent(false);
        static public void sendmessage()
        {
            usSendEvent.Set();
        }

        static public void Thread1()
        {
            int i = 0;
            while (true)
            {
                if (usSendEvent.WaitOne())
                {
                    object LockThis = new object();
                    lock (LockThis)
                    {
                        ++i;
                        Console.WriteLine("Hello {0}!", i);
                    }
                }
            }
        }
        static public void Thread2()
        {
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
            sendmessage();
            Thread.Sleep(100);
        }

        static void Main(string[] args)
        {
            Thread rec_th = new Thread(new ThreadStart(Thread1));
            rec_th.Priority = ThreadPriority.AboveNormal;
            rec_th.IsBackground = true;
            rec_th.Start();

            Thread displayoriginaldata_th = new Thread(new ThreadStart(Thread2));
            displayoriginaldata_th.Priority = ThreadPriority.BelowNormal;
            displayoriginaldata_th.IsBackground = true;
            displayoriginaldata_th.Start();

            while (true)
            {
                Thread.Sleep(100);
            }
        }
    }
}

结果:
Hello 1!
Hello 2!
Hello 3!
Hello 4!
Hello 5!
Hello 6!
Hello 7!
Hello 8!
Hello 9!
Hello 10!

还有啥逻辑藏在后面的,你自己研究研究,先别怀疑微软提供的这些基础设施。

出0入0汤圆

发表于 2020-7-31 17:26:52 | 显示全部楼层
uindex 发表于 2020-7-31 09:03
哥们你贴出来的代码没问题:

using System;

才疏学浅, 不知道它这个Lock 的用意。。。

出0入8汤圆

发表于 2020-7-31 19:01:17 | 显示全部楼层
浮华一生 发表于 2020-7-31 17:26
才疏学浅, 不知道它这个Lock 的用意。。。


别谦虚,同学,同学!如果有多个"线程1"同时执行,这个Lock就起作用了,确保一次只有一个线程执行Lock住的那段代码。

出0入0汤圆

发表于 2020-7-31 19:41:39 | 显示全部楼层
uindex 发表于 2020-7-31 19:01
别谦虚,同学,同学!如果有多个"线程1"同时执行,这个Lock就起作用了,确保一次只有一个线程执行Lock住 ...

他lock的局部变量啊 又不是 类里面的变量

出0入8汤圆

发表于 2020-7-31 20:49:06 | 显示全部楼层
浮华一生 发表于 2020-7-31 19:41
他lock的局部变量啊 又不是 类里面的变量


高手!你说的对,果然如此。

出0入0汤圆

 楼主| 发表于 2020-7-31 21:46:41 | 显示全部楼层
浮华一生 发表于 2020-7-31 07:43
不知道你详细代码。 你第一次WaitOne 进入了 有没有出来呢? 你这个里面的Lock ,呃,总觉得怪怪的,Lock ...

优先级设定注释了,Lock里面的局部变量改为Public了;单步执行线程一第一次进入后正常退出,线程二第二次sendmessage里面的usSendEv;ent.Set();也执行了,但是线程一仍然进不了。暂停后,系统停在 了main里面的Application.Run(new Form1());这句上。

出0入0汤圆

 楼主| 发表于 2020-8-1 00:12:35 | 显示全部楼层
icexiong 发表于 2020-7-31 08:44
你可以监控一下,线程1停在哪条代码,是停在 if (dataToSend.usSendEvent.WaitOne())   还是停在lock (Lock ...

线程1执行完第一次后,后面没有进入了,如何监控?

出0入0汤圆

发表于 2020-8-1 08:07:43 | 显示全部楼层
zw_7627 发表于 2020-8-1 00:12
线程1执行完第一次后,后面没有进入了,如何监控?

你线程1里边是while(1)的,怎么会退出,莫非,你的那个发送函数里有让线程结束的语句?

出0入0汤圆

发表于 2020-8-1 08:09:49 | 显示全部楼层
zw_7627 发表于 2020-8-1 00:12
线程1执行完第一次后,后面没有进入了,如何监控?

我掐指一算,你把sendframe(buf);这句注释掉,应该能再次进入这个线程

出0入0汤圆

 楼主| 发表于 2020-8-2 14:04:25 | 显示全部楼层
icexiong 发表于 2020-8-1 08:07
你线程1里边是while(1)的,怎么会退出,莫非,你的那个发送函数里有让线程结束的语句? ...

谢谢,找到退出的原因了。while(1)里面是个变量。
回帖提示: 反政府言论将被立即封锁ID 在按“提交”前,请自问一下:我这样表达会给举报吗,会给自己惹麻烦吗? 另外:尽量不要使用Mark、顶等没有意义的回复。不得大量使用大字体和彩色字。【本论坛不允许直接上传手机拍摄图片,浪费大家下载带宽和论坛服务器空间,请压缩后(图片小于1兆)才上传。压缩方法可以在微信里面发给自己(不要勾选“原图),然后下载,就能得到压缩后的图片】。另外,手机版只能上传图片,要上传附件需要切换到电脑版(不需要使用电脑,手机上切换到电脑版就行,页面底部)。
您需要登录后才可以回帖 登录 | 注册

本版积分规则

手机版|Archiver|amobbs.com 阿莫电子技术论坛 ( 粤ICP备2022115958号, 版权所有:东莞阿莫电子贸易商行 创办于2004年 (公安交互式论坛备案:44190002001997 ) )

GMT+8, 2024-3-29 19:47

© Since 2004 www.amobbs.com, 原www.ourdev.cn, 原www.ouravr.com

快速回复 返回顶部 返回列表