文档章节

奇怪的问题 thread里面使用了await,然后abort..

卜霞森
 卜霞森
发布于 2015/02/11 16:20
字数 275
阅读 26
收藏 0
点赞 0
评论 0

如题,自己做小工具,面向单个socket的tcp连接,使用thread处理TcpListener以及后续的数据接收,中间用到了await 和AcceptSocketAsync,然后我想在正在等待的时候取消listener状态。

目前使用的方式为直接thread.abort

但是在捕获到System.ObjectDisposedException

大致是说System.Net.Socket对象在企图对ta执行Dispose的时候已经被释放..



    class TcpServer_view_module : INotifyPropertyChanged
    {
...
        private TcpListener tcp_listener = null;
        private Socket tcp_socket = null;
...
        private async void thread_process_tcp_listener()
        {
            try
            {
                while (true)
                {
                    state = state_tcp_serve.waiting_client;
                    tcp_listener.Start(1);
                    tcp_socket = await tcp_listener.AcceptSocketAsync();
                    tcp_listener.Stop();
                    state = state_tcp_serve.connected;

                    if (tcp_socket != null)
                    {
                        while (true)
                        {
                            byte[] buffer = new byte[2048];
                            int len = tcp_socket.Receive(buffer);
                            if (len == 0)
                            {   //socket disconnect
                                break;
                            }
                            else
                            {
                                DataReceived(buffer, len);
                            }
                            tcp_socket.Dispose();
                        }
                    }
                }
            }
            catch (System.ObjectDisposedException dispose_e)
            {
...
            }
            catch (SystemException se)
            {
...
                state = state_tcp_serve.not_started;
            }
        }
...
        private void on_click()
        {
                switch (state)
                {
                    case state_tcp_serve.not_started:
...
                        thread_listener = new Thread(new ThreadStart(thread_process_tcp_listener));
                        thread_listener.Start();
                        break;

                    case state_tcp_serve.waiting_client:
                        tcp_listener.Stop();
                        if (thread_listener != null)
                        {
                            thread_listener.Abort();
                        }
                        if (tcp_socket != null)
                        {
                            tcp_socket.Dispose();
                            tcp_socket = null;
                        }
                        state = state_tcp_serve.not_started;
                        break;

                    case state_tcp_serve.connected:
                        state = state_tcp_serve.not_started;
                        if (thread_listener.IsAlive)
                        {
                            thread_listener.Abort();
                        }
                        if (tcp_socket != null)
                        {
                            tcp_socket.Dispose();
                            tcp_socket = null;
                        }
                        break;
                }            
        }


很奇怪的问题,大概有几个怀疑的点:

1、await虽然是语法糖,但是实际上还是拆解成异步来处理的,所以会导致异步操作未完成

2、

© 著作权归作者所有

共有 人打赏支持
卜霞森
粉丝 1
博文 47
码字总数 32877
作品 0
深圳
程序员
netty handler 里面代码需要同步

大家好! 我写的netty handler里面需要连接另外一个server,然后在后续的消息接收中对接收到的信息进行转发,但是netty的connect是异步的,handler里面又不能使用connectFuture.await()操作来等待...

xinglu ⋅ 2012/03/19 ⋅ 0

java多线程使用条件对象的时候,为什么建议用while来判断?

在看java核心技术讲到多线程中用条件对象,说到通常对await的调用应该在 while(!(ok to proceed)){condition.await();} 我奇怪为什么推荐使用while来判断,可不可以用if 在代码中实验了下,在...

Mr_Sky ⋅ 2014/08/04 ⋅ 2

c# 温故而知新: 线程篇(一)

c# 温故而知新: 线程篇(一) Thread 目录: 目录: 1 线程基础的简单介绍 2 线程同步与线程异步的简单介绍 3 前台线程与后台线程的简单介绍 4 细说下Thread 最为关键的构造函数 5 细说下Thr...

付翔 ⋅ 2013/01/08 ⋅ 0

使用Await减少回调嵌套

在开发的时候,有时候需要发很多请求,然后经常会面临嵌套回调的问题,即在一个回调里面又嵌了一个回调,导致代码层层缩进得很厉害,如下代码所示: 这样的代码看起来有点吃力,这种异步回调...

人人网FED ⋅ 2017/10/31 ⋅ 0

改善C#程序的建议7:正确停止线程

开发者总尝试对自己的代码有更多的控制。“让那个还在工作的线程马上停止下来”就是诸多要求中的一种。然而事与愿违,这里面至少存在两个问题: 第一个问题是:正如线程不能立即启动一样,线...

文艺小青年 ⋅ 2017/06/08 ⋅ 0

Java并发编程之AbstractQueuedSynchronizer源码分析

为什么要说AbstractQueuedSynchronizer呢? 因为AbstractQueuedSynchronizer是JUC并发包中锁的底层支持,AbstractQueuedSynchronizer是抽象同步队列,简称AQS,是实现同步器的基础组件,并发...

狂小白 ⋅ 06/10 ⋅ 0

记webmagic一个多线程问题排查和修复的过程

在webmagic的多线程抓取中有一个比较麻烦的问题:当Scheduler拿不到url的时候,不能立即退出,需要等到没抓完的线程都运行完毕,没有新url产生时,才能退出。之前使用Thread.sleep来实现,当...

黄亿华 ⋅ 2013/11/27 ⋅ 7

Java并发编程:线程间协作的两种方式:wait、notify、notifyAll和Condition

在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作。比如说最经典的生产者-消费者模型:当队列满时,生产者需要等待队列有空间才能继续往里面放入商品,而在等待的期间内...

Dreyer ⋅ 2015/11/13 ⋅ 0

java并发库中的阻塞队列--BlockingQueue

1.阻塞队列的概念 阻塞队列与普通队列的区别在于,当队列是空的时,从队列中获取元素的操作将会被阻塞,或者当队列是满时,往队列里添加元素的操作会被阻塞。试图从空的阻塞队列中获取元素的...

vshcxl ⋅ 2016/11/28 ⋅ 0

对Pthread线程进行简单的类封装

1.封装遇到的问题 将Pthreads线程封装为抽象类,这样用户在使用线程时,只需要继承一下这个抽象类,并实现相应的接口就可以了。这样做的好处是用户可以将注意力集中在线程所要执行的逻辑上,...

wbf961127 ⋅ 2017/11/13 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

CENTOS7防火墙命令记录

安装Firewall命令: yum install firewalld firewalld-config Firewall开启常见端口命令: firewall-cmd --zone=public --add-port=80/tcp --permanent firewall-cmd --zone=public --add-po......

cavion ⋅ 49分钟前 ⋅ 0

【C++】【STL】利用chromo来测量程序运行时间与日志时间打印精确到微秒

直接上代码吧,没啥好说的。头疼。 #include <iostream>#include <string>#include <ctime>#include <sstream>#include <iomanip>#include <thread>#include <chrono>using ......

muqiusangyang ⋅ 52分钟前 ⋅ 0

Mac环境下svn的使用

在Windows环境中,我们一般使用TortoiseSVN来搭建svn环境。在Mac环境下,由于Mac自带了svn的服务器端和客户端功能,所以我们可以在不装任何第三方软件的前提下使用svn功能,不过还需做一下简...

故久呵呵 ⋅ 今天 ⋅ 0

破解公司回应苹果“USB限制模式”:已攻破

本周四,苹果发表声明称 iOS 中加入了一项名为“USB 限制模式”的功能,可以防止 iPhone 在连接其他设备的时候被破解,并且强调这一功能并不是针对 FBI 等执法部门,为的是保护用户数据安全。...

六库科技 ⋅ 今天 ⋅ 0

MyBtais整合Spring Boot整合,TypeHandler对枚举类(enum)处理

概要 问题描述 我想用枚举类来表示用户当前状态,枚举类由 code 和 msg 组成,但我只想把 code 保存到数据库,查询处理,能知道用户当前状态,这应该怎么做呢?在 Spring 整合MyBatis 的时候...

Wenyi_Feng ⋅ 今天 ⋅ 0

synchronized与Lock的区别

# <center>王梦龙的读书笔记第一篇</center> ## <center>-synchronized与Lock的区别</centre> ###一、从使用场景来说 + synchronized 是能够注释代码块、类、方法但是它的加锁是和解锁使用一......

我不想加班 ⋅ 今天 ⋅ 0

VConsole的使用

手机端控制台打印输出,方便bug的排查。 首先需要引入vconsole.min.js 文件,然后在文件中创造实例。就能直接使用了。 var vConsole = new VConsole(); vConsole的文件地址...

大美琴 ⋅ 今天 ⋅ 0

Java NIO之字符集

1 字符集和编解码的概念 首先,解释一下什么是字符集。顾名思义,就是字符的集合。它的初衷是把现实世界的符号映射为计算机可以理解的字节。比如我创造一个字符集,叫做sex字符集,就包含两个...

士别三日 ⋅ 今天 ⋅ 0

Spring Bean基础

1、Bean之间引用 <!--如果Bean配置在同一个XML文件中,使用local引用--><ref bean="someBean"/><!--如果Bean配置在不同的XML文件中,使用ref引用--><ref local="someBean"/> 其实两种......

霍淇滨 ⋅ 今天 ⋅ 0

05、基于Consul+Upsync+Nginx实现动态负载均衡

1、Consul环境搭建 下载consul_0.7.5_linux_amd64.zip到/usr/local/src目录 cd /usr/local/srcwget https://releases.hashicorp.com/consul/0.7.5/consul_0.7.5_linux_amd64.zip 解压consu......

北岩 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部