網(wǎng)站首頁(yè) 編程語(yǔ)言 正文
正文
看Dio庫(kù)源碼的時(shí)候,發(fā)現(xiàn)其攔截器管理的邏輯處用到了一個(gè)Lock,這個(gè)Lock巧妙地利用了Completer和Future的機(jī)制來(lái)實(shí)現(xiàn),記錄一下。
/// Add lock/unlock API for interceptors.
class Lock {
Future? _lock;
late Completer _completer;
/// 標(biāo)識(shí)攔截器是否被上鎖
bool get locked => _lock != null;
/// Lock the interceptor.
///
///一旦請(qǐng)求/響應(yīng)攔截器被鎖,后續(xù)傳入的請(qǐng)求/響應(yīng)攔截器將被添加到隊(duì)列中,它們將不會(huì)
///繼續(xù),直到攔截器解鎖
void lock() {
if (!locked) {
_completer = Completer();
_lock = _completer.future;
}
}
/// Unlock the interceptor. please refer to [lock()]
void unlock() {
if (locked) {
//調(diào)用complete()
_completer.complete();
_lock = null;
}
}
/// Clean the interceptor queue.
void clear([String msg = 'cancelled']) {
if (locked) {
//complete[future] with an error
_completer.completeError(msg);
_lock = null;
}
}
/// If the interceptor is locked, the incoming request/response task
/// will enter a queue.
///
/// [callback] the function will return a `Future`
/// @nodoc
Future? enqueue(EnqueueCallback callback) {
if (locked) {
// we use a future as a queue
return _lock!.then((d) => callback());
}
return null;
}
}
原文鏈接:https://juejin.cn/post/7055918224528900127
相關(guān)推薦
- 2022-04-14 Python報(bào)mongod:?error?while?loading?shared?librarie
- 2022-08-06 SQL?Server備份數(shù)據(jù)庫(kù)的完整步驟_MsSql
- 2022-04-14 ASP.NET?Core基礎(chǔ)之Main方法講解_基礎(chǔ)應(yīng)用
- 2023-04-01 sqlserver字符串拼接的實(shí)現(xiàn)_MsSql
- 2024-01-27 DO、DTO、BO、VO、POJO區(qū)別
- 2022-04-12 詳解pyqt中解決國(guó)際化tr()函數(shù)不起作用的問(wèn)題_python
- 2023-12-26 Caused by: org.apache.ibatis.binding.BindingExcept
- 2022-10-01 使用flask如何獲取post請(qǐng)求參數(shù)_python
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細(xì)win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運(yùn)行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲(chǔ)小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運(yùn)算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認(rèn)證信息的處理
- Spring Security之認(rèn)證過(guò)濾器
- Spring Security概述快速入門(mén)
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯(cuò)誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實(shí)現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡(jiǎn)單動(dòng)態(tài)字符串(SD
- arthas操作spring被代理目標(biāo)對(duì)象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊(duì)列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠(yuǎn)程分支