锐客网

  1. 首页 > 睿知 > it技术 > >

java异步跑代码 java实现异步的几种方法( 三 )

IT技术代码


线程是一个独立的执行流，其本质是程序中一段并发执行的代码 。在异步调用机制中引入线程，在线程中完成耗时的工作 ， 其目的是让调用方的主线程继续执行后续代码而不需要等待被调方的结果返回 。由于不需要等待，这样我们就等于同时做了两件事情 ， 而这两件事情分别是在不同的执行流中执行，主调者在当前的主线程中执行，被调者在另外一个线程中执行，因此提高了程序的效率 ， 避免了界面的响应迟钝 。当被调者执行完成后，仍然采用回调通知主调者 。
例如　LongTimeWorker是一个用于完成耗时工作的线程 ， 同时又是消息通知者 。其耗时工作在run方法中完成，另外提供一个注册方法register ，  和一个消息通知方法notifyMessage，在run方法的最后，即耗时工作完成以后 ， 调用notifyMessage将消息广播出去 。
3 异步调用中超时问题的处理
异步调用通常都要加入超时机制，因为我们总是希望在一个指定的时间范围内返回一个结果 ， 即使没有得到结果也该有个超时通知 。这时我们需要使用“限时线程回调方式” ， 它在原有线程回调的基础上加上一个计时器Timer以计算消耗的时间，如果时间期限到了任务还没有执行完成即中断线程，并将超时消息广播出去 。LongTimeWorker类需要修改部分的代码如图8和图9所示 。
首先LongTimeWorker线程类增加了一个构造方法，其参数是超时时间timeout，构造方法的主要任务是创建一个定时器，每秒钟计时一次，若超时时间到则终止本线程，并广播超时消息 。LongTimeWorker线程类的第二个改变发生在其run方法中，线程一启动立即开始计时，完成工作后停止计时，并广播消息 。
4 结束语
异步调用是一种非阻塞式调用方式，用于在处理比较耗时的任务时保证程序性能不受到影响 。实现异步调用的关键在于要解决三个技术难题，它们分别是程序阻塞问题、异步消息的传递问题和超时问题 。本文介绍的方法采用并发线程、回调机制和计时器使上述问题得到了圆满解决 。
java 异步编程用异步输入输出流编写Socket进程通信程序
在Merlin中加入了用于实现异步输入输出机制的应用程序接口包java异步跑代码：java.nio（新的输入输出包，定义了很多基本类型缓冲(Buffer)），java.nio.channels(通道及选择器等，用于异步输入输出)，java.nio.charset（字符的编码解码） 。通道(Channel)首先在选择器(Selector)中注册自己感兴趣的事件，当相应的事件发生时，选择器便通过选择键(SelectionKey)通知已注册的通道 。然后通道将需要处理的信息 ， 通过缓冲（Buffer）打包，编码/解码,完成输入输出控制 。
通道介绍java异步跑代码：
这里主要介绍ServerSocketChannel和 SocketChannel.它们都是可选择的(selectable)通道，分别可以工作在同步和异步两种方式下（注意 ， 这里的可选择不是指可以选择两种工作方式，而是指可以有选择的注册自己感兴趣的事件） 。可以用channel.configureBlocking(Boolean )来设置其工作方式 。与以前版本的API相比较 ， ServerSocketChannel就相当于ServerSocket(ServerSocketChannel封装了ServerSocket),而SocketChannel就相当于Socket（SocketChannel封装了Socket） 。当通道工作在同步方式时，编程方法与以前的基本相似 ， 这里主要介绍异步工作方式 。
所谓异步输入输出机制，是指在进行输入输出处理时 ， 不必等到输入输出处理完毕才返回 。所以异步的同义语是非阻塞（None Blocking） 。在服务器端，ServerSocketChannel通过静态函数open()返回一个实例serverChl 。然后该通道调用serverChl.socket().bind()绑定到服务器某端口 ， 并调用register（Selector sel, SelectionKey.OP_ACCEPT）注册OP_ACCEPT事件到一个选择器中（ServerSocketChannel只可以注册OP_ACCEPT事件） 。当有客户请求连接时 ， 选择器就会通知该通道有客户连接请求，就可以进行相应的输入输出控制了java异步跑代码；在客户端 ， clientChl实例注册自己感兴趣的事件后（可以是OP_CONNECT,OP_READ,OP_WRITE的组合），调用clientChl.connect(InetSocketAddress )连接服务器然后进行相应处理 。注意，这里的连接是异步的，即会立即返回而继续执行后面的代码 。

推荐阅读


上一篇：jquery的is方法，jquery中常用的方法

下一篇：直播采集画笔技巧，直播采集画笔技巧是什么