I/O接口_overlapping

I/O接口_overlappingOverlappedI/O是Windows系统上的AsynchronousI/Oimplementation。啥叫asynchronousI/O?借用LinuxManpage中对AIO的

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

Overlapped I/O是Windows系统上的Asynchronous I/O implementation。啥叫asynchronous I/O ?借用Linux Man page中对AIO的介绍:

The POSIX asynchronous I/O (AIO) interface allows applications to initiate one or more I/O operations that are performed asynchronously (i.e., in the background). The application can elect to be notified of completion of the I/O operation in a variety of ways: by delivery of a signal, by instantiation of a thread, or no notification at all.

AIO让应用发起一个操作请求,让这个请求被异步地执行。应用可以选择在操作完成时被通知到或者不被通知。 

typedef struct _OVERLAPPED {
  ULONG_PTR Internal;
  ULONG_PTR InternalHigh;
  union {
    struct {
      DWORD Offset;
      DWORD OffsetHigh;
    };
    PVOID  Pointer;
  };
  HANDLE    hEvent;
} OVERLAPPED, *LPOVERLAPPED;

 

关于这个数据结构的详细介绍可以参考:http://msdn.microsoft.com/en-us/library/windows/desktop/ms684342(v=vs.85).aspx。 概括来说,Internal,InternalHigh都是内部使用的,不建议直接使用;Offset + OffsetHigh用于有offset概念的handle;Pointer是保留给系统使用的;hEvent指向一个event,当操作完成后,这个event会被系统设置成signalled状态。

看起来,这个数据结构本身并没有提供很多信息,那如何使用这个数据结构呢?

  

OVERLAPPED使用之一:内核对象(handle)

无论是对一个Socket或者文件或者其他什么对象操作,总有一个handle来指向这个对象。当对这个对象发出操作请求后,过一段时间就可以使用该handle和Overlapped对象进行查询,之前的那个请求是否完成。下面是一个例子:

用overlapped模型读一个磁盘文件内容。

   1.把设备句柄看作同步对象,ReadFile将设备句柄设为无信号。ReadFile 异步I/O字节位置必须在OVERLAPPED结构中指定。

   2.完成I/O,设置信息状态。为有信号。

   3.WaitForSingleObject或WaitForMultipleObject判断或者异步设备调用GetOverLappedResult函数。

 

#include <Windows.h>


#define READ_SIZE 1024

int main()

{

    BOOL rc;

    HANDLE hFile;

    DWORD numread;

    OVERLAPPED overlap;

    
char buf[READ_SIZE];

    
char szPath[MAX_PATH];

    GetWindowsDirectory(szPath, 
sizeof(szPath));

    strcat(szPath, 

\\WINHLP32.EXE
);

    hFile = CreateFile( szPath,

                    GENERIC_READ,

                    FILE_SHARE_READ|FILE_SHARE_WRITE,

                    NULL,

                    OPEN_EXISTING,

                    FILE_FLAG_OVERLAPPED,

                    NULL

                );

    
if (hFile == INVALID_HANDLE_VALUE)

    {

        printf(

Could not open %s\n
, szPath);

        
return –
1;

    }

    memset(&overlap, 
0
sizeof(overlap));

    overlap.Offset = 
1500;

    rc = ReadFile(

                hFile,

                buf,

                READ_SIZE,

                &numread,

                &overlap

            );

    printf(

Issued read request\n
);

    
if (rc)

    {

        printf(

Request was returned immediately\n
);

    }

    
else

    {

        
if (GetLastError() == ERROR_IO_PENDING)

        {

            printf(

Request queued, waiting…\n
);

            WaitForSingleObject(hFile, INFINITE);

            printf(

Request completed.\n
);

            rc = GetOverlappedResult(

                                    hFile,

                                    &overlap,

                                    &numread,

                                    FALSE

                                );

            printf(

Result was %d\n
, rc);

        }

        
else

        {

            printf(

Error reading file\n
);

        }

    }

    CloseHandle(hFile);

    
return EXIT_SUCCESS;

}

 

OVERLAPPED使用之二: 事件通知

每一个异步操作,都有一个OVERLAPPED的instance与之相关联,因此,当之前提交的异步操作完成后,可以使用OVERLAPPED中的hEvent来获取通知。写完示例程序可以贴出来。

 

Limitation:

1. WaitForMultipleObjects最多可以等待MAXIMUM_WAIT_OBJECTS(64)个对象,当提交的请求比较多(>64)时,就没法同时等。

2. 只能使用一个file handle;

 

OVERLAPPED使用之三: COMPLETION ROUTINE

另外一种方法是注册一个回调函数,在一个Overlapped I/O完成之后,系统调用该回调函数。OS在有信号状态下(设备句柄),才会调用回调函数(可能有很多APCS等待处理了),传给它完成I/O请求的错误码,传输字节数和Overlapped结构的地址。看看OVERLAPPED的定义,这个回调函数是没法跟OVERLAPPED进行关联了,那在哪里关联呢?答案是在每次请求时关联,比如WSARecv, ReadFileEx, WSASend 等函数都有一个参数为LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine,这就是call back函数可以注册的地方。写完示例程序可以贴出来。

可以注意到,在这种方式时,并不需要每个IO request创建一个OVERLAPPED实例,因为没有用到OVERLAPPED里的任何信息。大家共享一个就可以了。

 

Limitation:

1. 只有发出overlapped IO请求的线程才可以提供callback函数,每个callback都会创建一个新线程,那么就是每个request都要创建线程,用完销毁,开销太大。

2. 只能使用一个file handle;

 

OVERLAPPED使用之四: IOCP

IOCP是在OVERLAPPED IO基础上的扩展。功能更加强大。OVERLAPPED IO会创建IO request 队列,当有异步请求时,就把请求放到这个队列里,系统会从队列中取请求并处理;IOCP主要是接近请求完成后通知的问题,IOCP是又创建了一个完成队列,当OVERLAPPED IO中的request 队列中有request被完成时,就放到IOCP的完成队列中,App的GetQueuedCompletionStatus从完成队列中取一个completion packet,进行处理。

所以,IOCP是以OVERLAPPED IO为基础的完成通知机制,对OVERLAPPED数据结构中的信息被不真正关心。但是必须要有一个OVERLAPPED的instance。

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/167132.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • xshell的安装和使用_Xshell命令

    xshell的安装和使用_Xshell命令Xshell安装Xshell安装完后提示更新到最新版本

  • java常量有哪些_Java中的常量有哪些?

    java常量有哪些_Java中的常量有哪些?JAVA常量就是在程序中固定不变的值,是不能改变的数据。例如数字1、字符“a”、浮点数3.2等。那么java的常量有哪些呢?在Java中,常量包括整型常量、浮点数常量、布尔常量、字符常量等。下面我们就一起来看看java中的这些常量。1.整型常量整型常量是整数类型的数据,有二进制、八进制、十进制和十六进制4种表示形式具体表示形式如下。二进制:由数字0和1组成的数字序列。在JDK7.0中允许使用字面值…

  • 次世代3A游戏开发将飙至1.5亿美元,游戏时长将更短

    次世代3A游戏开发将飙至1.5亿美元,游戏时长将更短即将翻过的这个世代,是大作的时代,涌现了一大批的大作,譬如《荒野大镖客2》、《GTA5》、《巫师3》等游戏。当然也是预算高涨、不断跳票和开发商经常加班加点的时代。随着PS5和XSX即将到来,随之一起的将是有史以来细节最丰富和预算更贵的游戏世界,问题就出现了:游戏行业还会继续痴迷于这么庞大世界的游戏吗?在GameBabLive会议上,SIE前总裁ShawnLayden表达了对次世代游戏开发成本倍增的担忧。他认为次世代3A游戏的开发将不可避免地从今天的8000万美元飙升至1.5亿美元。因此Lay

  • 在select标签中添加a标签

    在select标签中添加a标签

  • PC傻瓜式安装黑苹果并打造成全能逆向工作站–更新至2021.12.20

    PC傻瓜式安装黑苹果并打造成全能逆向工作站–更新至2021.12.20安装黑苹果有多简单原版Windows镜像安装大家都会,当然Ghost安装除外喔,太“乡村范儿”了。Windows操作系统的安装,无非下列四个步骤。准备镜像→写镜像到U盘→从U盘安装系统→系统自定义配置现在我们安装黑苹果也是同样的流程。先说一下本机的配置:2014年1999元买的宁美国度的组装台式机*CPU:i34160*GPU:HD4400CPU自带*RAM:4…

  • sqlserver 视图创建索引_数据库视图可以建立索引吗

    sqlserver 视图创建索引_数据库视图可以建立索引吗文章目录操作前准备一、视图1、创建视图2、更新视图3、删除视图二、索引1、聚集索引2、非聚集索引3、创建索引语法格式:4、删除索引代码全部示例操作前准备一、视图1、创建视图视图(View)是从一个或多个表或其它视图导出的,用来导出视图的表称为基表,导出的视图又称为虚表。在数据库中,只存储视图的定义,不存放视图对应的数据,这些数据仍然存放在原来的基表中。使用视图前,必须先创建视图,创建…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号