代码拉取完成,页面将自动刷新
同步操作将从 方瑾/async 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
#ifndef __IO_H__
#define __IO_H__
#include<signal.h>
#include<pthread.h>
#pragma comment(lib, "pthreadVC2.lib")
#include"array.h"
enum _IoType {
IO, SocketIO
};
typedef enum _IoType IoType;
enum _eventType {
AccessFileEvent
};
typedef enum _eventType EventType;
typedef struct ioEvent {
string id;
string path;
let result;
string error;
let otherParams;
let callback;
IoType ioType;
EventType eventType;
}*IoEvent;
#define newIoEvent() NEW(struct ioEvent)
typedef struct serviceThreadInfo {
pthread_t pid;
pthread_cond_t notifyCond;
pthread_cond_t waitTimeoutCond;
pthread_mutex_t waitTimeout;
pthread_mutex_t notify;
pthread_mutex_t undeal;
pthread_mutex_t finish;
pthread_mutex_t event;
}*ServiceThreadInfo;
#define newServiceThreadInfo() NEW(struct serviceThreadInfo)
typedef struct ioService {
Array undealQueue;
Array finishQueue;
ServiceThreadInfo serviceThreadInfo;
}*IoService;
#define newIoService() NEW(struct ioService)
// io¼
void runIO(let args);
void creatIoServicePthread(IoService service);
#endif // !__IO_H__
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。