1

我有一个用 C 编写的现有 C API，它大量使用从函数返回的状态代码进行错误处理。我试图了解使用 libdispatch 处理此类情况的首选方法。

这是一个示例函数。RETURN_ERROR 和相关宏只是调用一个返回错误代码并打印消息的函数。

int
mport_db_prepare(sqlite3 *db, sqlite3_stmt **stmt, const char * fmt, ...)
{
  va_list args;
  char *sql;

  va_start(args, fmt);
  sql = sqlite3_vmprintf(fmt, args);
  va_end(args);

  if (sql == NULL)
    RETURN_ERROR(MPORT_ERR_FATAL, "Couldn't allocate memory for sql statement");

  if (sqlite3_prepare_v2(db, sql, -1, stmt, NULL) != SQLITE_OK) {
    SET_ERRORX(MPORT_ERR_FATAL, "sql error preparing '%s': %s", sql, sqlite3_errmsg(db));
    sqlite3_free(sql);
    RETURN_CURRENT_ERROR;
  }

  sqlite3_free(sql);

  return MPORT_OK;
}

我想在 sql 访问位周围使用串行队列，并且知道我可以dispatch_sync用来返回值。但是，我也读到过很多同步调用很容易陷入死锁。

这种界面的最佳实践是什么？传递一个带有成功/失败处理程序的块？我会提供一个dispatch_queue_t参数让完成块在用户指定的队列上运行吗？

4

1 回答 1

1

这是您可以使用的示例模板。这是我的首选方法。我是直接在浏览器中输入的，所以可能会有一些小错误（请编辑）：

typedef void (^completion_block_t)(int error_code);

static dispatch_once_t init_once;
static dispatch_queue_t db_queue;

void perform_init(void __unused *ctx) {
    db_queue = dispatch_queue_create("com.mycompany.db_queue", DISPATCH_QUEUE_SERIAL);
}

void perform_some_async_operation(dispatch_queue_t completion_queue, completion_block_t completion_block) {
    dispatch_once_f(&init_once, NULL, perform_init);

    if (completion_block) {
        completion_block = Block_copy(completion_block)

        if (!completion_queue) {
            completion_queue = dispatch_get_global_queue(qos_class_self(), 0);
        }
    }

    dispatch_async(db_queue, ^{
        int error_code = 0;

        ...

        if (completion_block) {
            dispatch_async(completion_queue, ^{
                completion_block(error_code);
            });
        }
    });
}

请注意，如果您还想提供 API 的同步版本，最好使用它来实现您的异步版本，而不是相反。这样，系统可以更好地跟踪优先级继承的依赖关系。例如：

int perform_some_sync_operation() {
    dispatch_once_f(&init_once, NULL, perform_init);

    __block int error_code = 0;

    dispatch_sync(db_queue, ^{
        ...
    });

    return error_code;
}

void perform_some_async_operation(dispatch_queue_t completion_queue, completion_block_t completion_block) {
    dispatch_queue_t execution_queue = dispatch_get_global_queue(qos_class_self(), 0);

    if (completion_block) {
        completion_block = Block_copy(completion_block)

        if (!completion_queue) {
            completion_queue = execution_queue;
        }
    }

    dispatch_async(execution_queue, ^{
        int error_code = perform_some_sync_operation();

        if (completion_block) {
            dispatch_async(completion_queue, ^{
                completion_block(error_code);
            });
        }
    });
}

如果您的代码预计将在比 Yosemite 或 iOS 8 更早的系统上运行，您将需要在 qos_class_self() 不可用时进行回退。例如：

completion_queue = dispatch_get_global_queue(&qos_class_self ? qos_class_self() : DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
于 2015-11-26T05:47:46.767 回答