libevent_struct event

2015-05-06 10:38:20   1  举报





`libevent_struct event`是libevent库中的一个核心数据结构，用于表示一个事件。这个结构体包含了关于事件的详细信息，如事件类型、触发方式、回调函数等。通过操作这个结构体，可以实现对事件的创建、修改、删除等操作。在libevent库中，事件是实现异步I/O和非阻塞网络编程的关键。当某个事件发生时（如文件描述符可读、可写或发生错误），libevent库会自动调用相应的回调函数进行处理，从而实现高效的并发处理。

libevet

作者其他创作

大纲/内容

create

StreamElement

boolean isWatermark()

has a

StreamElementQueueEntry

+ operation1(params):returnType- operation2(params)- operation3()

CompletableFuture

boolean complete(T value)CompletableFuture whenCompleteAsync()

StreamElementQueue

void put(StreamElementQueueEntry<T> streamElementQueueEntry) boolean tryPut(StreamElementQueueEntry<T> streamElementQueueEntry)AsyncResult peekBlockingly() AsyncResult poll()

AsyncResult

AsyncCollectionResult asResultCollection()

UnorderedStreamElementQueue

+ ArrayDeque<Set<StreamElementQueueEntry<?>>> uncompletedQueue+ ArrayDeque<StreamElementQueueEntry<?>> completedQueue+ Set<StreamElementQueueEntry<?>> firstSet+ Set<StreamElementQueueEntry<?>> lastSet

+ void onCompleteHandler(StreamElementQueueEntry<?> streamElementQueueEntry)

OrderedStreamElementQueue

+ ArrayDeque<StreamElementQueueEntry<?>> queue

+ onCompleteHandler(StreamElementQueueEntry<?> streamElementQueueEntry)

StreamRecordQueueEntry

CompletableFuture<Watermark> future

WatermarkQueueEntry

CompletableFuture<Collection<OUT>> resultFuture