Skip to content

Latest commit

 

History

History
163 lines (142 loc) · 4 KB

others.md

File metadata and controls

163 lines (142 loc) · 4 KB

Other Tasks

本文档介绍结构较为简单的任务

FileTasks

文件相关任务用于对打开的fd进行异步读写等操作，包括FileIOTask, FileVIOTask, FileSyncTask

FileIOTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int
  • get_retval() -> int
    • 文件读写操作的返回值
  • set_callback(Callable[[wf.FileIOTask], None]) -> None
  • set_user_data(object) -> None
  • get_user_data() -> object
  • get_fd() -> int
    • 获取和该任务相关的fd
  • get_offset() -> int
  • get_count() -> int
    • 文件操作的字节数
  • get_data() -> bytes
    • 文件读取操作的结果

FileVIOTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int
  • get_retval() -> int
    • 文件写操作的返回值
  • set_callback(Callable[[wf.FileVIOTask], None]) -> None
  • set_user_data(object) -> None
  • get_user_data() -> object
  • get_fd() -> int
    • 获取和该任务相关的fd
  • get_offset() -> int
  • get_data() -> list[bytes]
    • 文件读取操作的结果

FileSyncTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int
  • get_retval() -> int
    • 文件操作的返回值
  • set_callback(Callable[[wf.FileSyncTask], None]) -> None
  • set_user_data(object) -> None
  • get_user_data() -> object
  • get_fd() -> int
    • 获取和该任务相关的fd

TimerTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int
  • set_callback(Callable[[wf.TimerTask], None]) -> None
  • set_user_data(object) -> None
  • get_user_data() -> object

CounterTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int
  • set_callback(Callable[[wf.CounterTask], None]) -> None
  • set_user_data(object) -> None
  • get_user_data() -> object
  • count() -> None
    • 增加一次计数

GoTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int
  • set_callback(Callable[[wf.GoTask], None]) -> None
  • set_user_data(object) -> None
  • get_user_data() -> object

EmptyTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int

DynamicTask

  • start() -> None
  • dismiss() -> None
  • get_state() -> int
  • get_error() -> int

任务工厂等

  • wf.create_pread_task(int fd, int count, int offset, callback) -> wf.FileIOTask
  • wf.create_pwrite_task(int fd, bytes data, int count, int offset, callback) -> wf.FileIOTask
    • 若data长度小于count，则以真实长度为准
  • wf.create_pwritev_task(int fd, list[bytes], int offset, callback) -> wf.FileVIOTask
  • wf.create_fsync_task(int fd, callback) -> wf.FileSyncTask
  • wf.create_fdsync_task(int fd, callback) -> wf.FileSyncTask
  • wf.create_timer_task(int microseconds, callback) -> wf.TimerTask
  • wf.create_counter_task(int target, callback) -> wf.CounterTask
  • wf.create_counter_task(str name, int target, callback) -> wf.TimerTask
  • wf.count_by_name(str name, int n) -> None
    • 通过任务名称进行n次计数
  • wf.create_go_task(Callable[[*args, **kwargs], None], args, kwargs) -> wf.GoTask
  • wf.create_empty_task() -> wf.EmptyTask
  • wf.create_dynamic_task(Callable[[wf.DynamicTask], wf.SubTask]) -> wf.DynamicTask

示例

# GoTask
import pywf as wf

def go_callback(task):
    print("state: {}, error: {}".format(
        task.get_state(), task.get_error()
    ))
    print("user_data: ", task.get_user_data())
    pass

def go(a, b, c):
    print(a, b, c)

go_task = wf.create_go_task(go, 1, "pywf", 3.1415926)
go_task.set_user_data({"key": "value"})
go_task.set_callback(go_callback)
go_task.start()
wf.wait_finish()
# CounterTask
import pywf as wf

def counter_callback(task):
    print('counter callback')

task = wf.create_counter_task("counter", 2, counter_callback)
task.count()
task.start()
wf.count_by_name("counter", 1)
wf.wait_finish()
# TimerTask
import pywf as wf
import time

start = 0

def timer_callback(task):
    stop = time.time()
    print(stop - start)

# sleep for 10 ms
task = wf.create_timer_task(10 * 1000, timer_callback)
start = time.time()
task.start()
wf.wait_finish()