Demo崩溃

[huanglin2]

connection.h 文件 write_queue_队列，在不同线程进行调用，未加锁 线程1： void response_interal(uint64_t req_id, std::shared_ptr data, request_type req_type = request_type::req_res) { assert(data->size() < MAX_BUF_LEN);

write_queue_.emplace_back(message_type{req_id, req_type, std::move(data)});
if (write_queue_.size() > 1) {
  return;
}

write();

} 线程2： void on_write(asio::error_code ec, std::size_t length) { if (ec) { print(ec); if (on_neterr) { (*on_neterr)(shared_from_this(), ec.message()); } close(false); return; }

if (has_closed()) {
  return;
}

write_queue_.pop_front();

if (!write_queue_.empty()) {
  write();
}

}

[qicosmos]

response_interal这个是内部的函数，内部会保证这个函数是单线程执行的，怎么会在外部多线程调用呢？有测试代码吗？

[huanglin2]

response_interal这个是内部的函数，内部会保证这个函数是单线程执行的，怎么会在外部多线程调用呢？有测试代码吗？

项目工程demo test_callback();

[qicosmos]

请拉最新代码验证一下。

[huanglin2]

没问题了