IDictionaryExtensions.cs 48 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156
  1. using Masuit.Tools.Systems;
  2. using System;
  3. using System.Collections.Concurrent;
  4. using System.Collections.Generic;
  5. using System.Linq;
  6. using System.Threading.Tasks;
  7. namespace Masuit.Tools
  8. {
  9. public static class IDictionaryExtensions
  10. {
  11. /// <summary>
  12. /// 添加或更新键值对
  13. /// </summary>
  14. /// <param name="this"></param>
  15. /// <param name="that">另一个字典集</param>
  16. public static void AddOrUpdate<TKey, TValue>(this IDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that)
  17. {
  18. foreach (var item in that)
  19. {
  20. @this[item.Key] = item.Value;
  21. }
  22. }
  23. /// <summary>
  24. /// 添加或更新键值对
  25. /// </summary>
  26. /// <param name="this"></param>
  27. /// <param name="that">另一个字典集</param>
  28. public static void AddOrUpdate<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that)
  29. {
  30. foreach (var item in that)
  31. {
  32. @this[item.Key] = item.Value;
  33. }
  34. }
  35. /// <summary>
  36. /// 添加或更新键值对
  37. /// </summary>
  38. /// <param name="this"></param>
  39. /// <param name="that">另一个字典集</param>
  40. public static void AddOrUpdate<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that)
  41. {
  42. foreach (var item in that)
  43. {
  44. @this[item.Key] = item.Value;
  45. }
  46. }
  47. /// <summary>
  48. /// 添加或更新键值对
  49. /// </summary>
  50. /// <param name="this"></param>
  51. /// <param name="that">另一个字典集</param>
  52. public static void AddOrUpdateTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that)
  53. {
  54. foreach (var item in @this)
  55. {
  56. that[item.Key] = item.Value;
  57. }
  58. }
  59. /// <summary>
  60. /// 添加或更新键值对
  61. /// </summary>
  62. /// <param name="this"></param>
  63. /// <param name="that">另一个字典集</param>
  64. public static void AddOrUpdateTo<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that)
  65. {
  66. foreach (var item in @this)
  67. {
  68. that[item.Key] = item.Value;
  69. }
  70. }
  71. /// <summary>
  72. /// 添加或更新键值对
  73. /// </summary>
  74. /// <param name="this"></param>
  75. /// <param name="that">另一个字典集</param>
  76. public static void AddOrUpdateTo<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that)
  77. {
  78. foreach (var item in @this)
  79. {
  80. that[item.Key] = item.Value;
  81. }
  82. }
  83. /// <summary>
  84. /// 添加或更新键值对
  85. /// </summary>
  86. /// <param name="this"></param>
  87. /// <param name="key">键</param>
  88. /// <param name="addValue">添加时的值</param>
  89. /// <param name="updateValueFactory">更新时的操作</param>
  90. public static TValue AddOrUpdate<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, TValue addValue, Func<TKey, TValue, TValue> updateValueFactory)
  91. {
  92. if ([email protected](key, addValue))
  93. {
  94. @this[key] = updateValueFactory(key, @this[key]);
  95. }
  96. return @this[key];
  97. }
  98. /// <summary>
  99. /// 添加或更新键值对
  100. /// </summary>
  101. /// <param name="this"></param>
  102. /// <param name="key">键</param>
  103. /// <param name="addValue">添加时的值</param>
  104. /// <param name="updateValueFactory">更新时的操作</param>
  105. public static TValue AddOrUpdate<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, TKey key, TValue addValue, Func<TKey, TValue, TValue> updateValueFactory)
  106. {
  107. if ([email protected](key, addValue))
  108. {
  109. @this[key] = updateValueFactory(key, @this[key]);
  110. }
  111. return @this[key];
  112. }
  113. /// <summary>
  114. /// 添加或更新键值对
  115. /// </summary>
  116. /// <typeparam name="TKey"></typeparam>
  117. /// <typeparam name="TValue"></typeparam>
  118. /// <param name="this"></param>
  119. /// <param name="key">键</param>
  120. /// <param name="addValue">添加时的值</param>
  121. /// <param name="updateValueFactory">更新时的操作</param>
  122. public static TValue AddOrUpdate<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, TKey key, TValue addValue, Func<TKey, TValue, TValue> updateValueFactory)
  123. {
  124. if ([email protected](key, addValue))
  125. {
  126. @this[key] = updateValueFactory(key, @this[key]);
  127. }
  128. return @this[key];
  129. }
  130. /// <summary>
  131. /// 添加或更新键值对
  132. /// </summary>
  133. /// <typeparam name="TKey"></typeparam>
  134. /// <typeparam name="TValue"></typeparam>
  135. /// <param name="this"></param>
  136. /// <param name="key">键</param>
  137. /// <param name="addValue">添加时的值</param>
  138. /// <param name="updateValueFactory">更新时的操作</param>
  139. public static async Task<TValue> AddOrUpdateAsync<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, TValue addValue, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  140. {
  141. if ([email protected](key, addValue))
  142. {
  143. @this[key] = await updateValueFactory(key, @this[key]);
  144. }
  145. return @this[key];
  146. }
  147. /// <summary>
  148. /// 添加或更新键值对
  149. /// </summary>
  150. /// <typeparam name="TKey"></typeparam>
  151. /// <typeparam name="TValue"></typeparam>
  152. /// <param name="this"></param>
  153. /// <param name="key">键</param>
  154. /// <param name="addValue">添加时的值</param>
  155. /// <param name="updateValueFactory">更新时的操作</param>
  156. public static async Task<TValue> AddOrUpdateAsync<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, TKey key, TValue addValue, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  157. {
  158. if ([email protected](key, addValue))
  159. {
  160. @this[key] = await updateValueFactory(key, @this[key]);
  161. }
  162. return @this[key];
  163. }
  164. /// <summary>
  165. /// 添加或更新键值对
  166. /// </summary>
  167. /// <typeparam name="TKey"></typeparam>
  168. /// <typeparam name="TValue"></typeparam>
  169. /// <param name="this"></param>
  170. /// <param name="key">键</param>
  171. /// <param name="addValue">添加时的值</param>
  172. /// <param name="updateValueFactory">更新时的操作</param>
  173. public static async Task<TValue> AddOrUpdateAsync<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, TKey key, TValue addValue, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  174. {
  175. if ([email protected](key, addValue))
  176. {
  177. @this[key] = await updateValueFactory(key, @this[key]);
  178. }
  179. return @this[key];
  180. }
  181. /// <summary>
  182. /// 添加或更新键值对
  183. /// </summary>
  184. /// <typeparam name="TKey"></typeparam>
  185. /// <typeparam name="TValue"></typeparam>
  186. /// <param name="this"></param>
  187. /// <param name="key">键</param>
  188. /// <param name="addValue">添加时的值</param>
  189. /// <param name="updateValue">更新时的值</param>
  190. public static TValue AddOrUpdate<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, TValue addValue, TValue updateValue)
  191. {
  192. if ([email protected](key, addValue))
  193. {
  194. @this[key] = updateValue;
  195. }
  196. return @this[key];
  197. }
  198. /// <summary>
  199. /// 添加或更新键值对
  200. /// </summary>
  201. /// <param name="this"></param>
  202. /// <param name="key">键</param>
  203. /// <param name="addValue">添加时的值</param>
  204. /// <param name="updateValue">更新时的值</param>
  205. public static TValue AddOrUpdate<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, TKey key, TValue addValue, TValue updateValue)
  206. {
  207. if ([email protected](key, addValue))
  208. {
  209. @this[key] = updateValue;
  210. }
  211. return @this[key];
  212. }
  213. /// <summary>
  214. /// 添加或更新键值对
  215. /// </summary>
  216. /// <typeparam name="TKey"></typeparam>
  217. /// <typeparam name="TValue"></typeparam>
  218. /// <param name="this"></param>
  219. /// <param name="key">键</param>
  220. /// <param name="addValue">添加时的值</param>
  221. /// <param name="updateValue">更新时的值</param>
  222. public static TValue AddOrUpdate<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, TKey key, TValue addValue, TValue updateValue)
  223. {
  224. if ([email protected](key, addValue))
  225. {
  226. @this[key] = updateValue;
  227. }
  228. return @this[key];
  229. }
  230. /// <summary>
  231. /// 添加或更新键值对
  232. /// </summary>
  233. /// <typeparam name="TKey"></typeparam>
  234. /// <typeparam name="TValue"></typeparam>
  235. /// <param name="this"></param>
  236. /// <param name="that">另一个字典集</param>
  237. /// <param name="updateValueFactory">更新时的操作</param>
  238. public static void AddOrUpdate<TKey, TValue>(this IDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, TValue> updateValueFactory)
  239. {
  240. foreach (var item in that)
  241. {
  242. AddOrUpdate(@this, item.Key, item.Value, updateValueFactory);
  243. }
  244. }
  245. /// <summary>
  246. /// 添加或更新键值对
  247. /// </summary>
  248. /// <typeparam name="TKey"></typeparam>
  249. /// <typeparam name="TValue"></typeparam>
  250. /// <param name="this"></param>
  251. /// <param name="that">另一个字典集</param>
  252. /// <param name="updateValueFactory">更新时的操作</param>
  253. public static void AddOrUpdate<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, TValue> updateValueFactory)
  254. {
  255. foreach (var item in that)
  256. {
  257. AddOrUpdate(@this, item.Key, item.Value, updateValueFactory);
  258. }
  259. }
  260. /// <summary>
  261. /// 添加或更新键值对
  262. /// </summary>
  263. /// <typeparam name="TKey"></typeparam>
  264. /// <typeparam name="TValue"></typeparam>
  265. /// <param name="this"></param>
  266. /// <param name="that">另一个字典集</param>
  267. /// <param name="updateValueFactory">更新时的操作</param>
  268. public static void AddOrUpdate<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, TValue> updateValueFactory)
  269. {
  270. foreach (var item in that)
  271. {
  272. AddOrUpdate(@this, item.Key, item.Value, updateValueFactory);
  273. }
  274. }
  275. /// <summary>
  276. /// 添加或更新键值对
  277. /// </summary>
  278. /// <typeparam name="TKey"></typeparam>
  279. /// <typeparam name="TValue"></typeparam>
  280. /// <param name="this"></param>
  281. /// <param name="that">另一个字典集</param>
  282. /// <param name="updateValueFactory">更新时的操作</param>
  283. public static Task AddOrUpdateAsync<TKey, TValue>(this IDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  284. {
  285. return that.ForeachAsync(item => AddOrUpdateAsync(@this, item.Key, item.Value, updateValueFactory));
  286. }
  287. /// <summary>
  288. /// 添加或更新键值对
  289. /// </summary>
  290. /// <typeparam name="TKey"></typeparam>
  291. /// <typeparam name="TValue"></typeparam>
  292. /// <param name="this"></param>
  293. /// <param name="that">另一个字典集</param>
  294. /// <param name="updateValueFactory">更新时的操作</param>
  295. public static Task AddOrUpdateAsync<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  296. {
  297. return that.ForeachAsync(item => AddOrUpdateAsync(@this, item.Key, item.Value, updateValueFactory));
  298. }
  299. /// <summary>
  300. /// 添加或更新键值对
  301. /// </summary>
  302. /// <typeparam name="TKey"></typeparam>
  303. /// <typeparam name="TValue"></typeparam>
  304. /// <param name="this"></param>
  305. /// <param name="that">另一个字典集</param>
  306. /// <param name="updateValueFactory">更新时的操作</param>
  307. public static Task AddOrUpdateAsync<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  308. {
  309. return that.ForeachAsync(item => AddOrUpdateAsync(@this, item.Key, item.Value, updateValueFactory));
  310. }
  311. /// <summary>
  312. /// 添加或更新键值对
  313. /// </summary>
  314. /// <typeparam name="TKey"></typeparam>
  315. /// <typeparam name="TValue"></typeparam>
  316. /// <param name="this"></param>
  317. /// <param name="that">另一个字典集</param>
  318. /// <param name="updateValueFactory">更新时的操作</param>
  319. public static void AddOrUpdateTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, TValue> updateValueFactory)
  320. {
  321. foreach (var item in @this)
  322. {
  323. AddOrUpdate(that, item.Key, item.Value, updateValueFactory);
  324. }
  325. }
  326. /// <summary>
  327. /// 添加或更新键值对
  328. /// </summary>
  329. /// <typeparam name="TKey"></typeparam>
  330. /// <typeparam name="TValue"></typeparam>
  331. /// <param name="this"></param>
  332. /// <param name="that">另一个字典集</param>
  333. /// <param name="updateValueFactory">更新时的操作</param>
  334. public static void AddOrUpdateTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, NullableDictionary<TKey, TValue> that, Func<TKey, TValue, TValue> updateValueFactory)
  335. {
  336. foreach (var item in @this)
  337. {
  338. AddOrUpdate(that, item.Key, item.Value, updateValueFactory);
  339. }
  340. }
  341. /// <summary>
  342. /// 添加或更新键值对
  343. /// </summary>
  344. /// <typeparam name="TKey"></typeparam>
  345. /// <typeparam name="TValue"></typeparam>
  346. /// <param name="this"></param>
  347. /// <param name="that">另一个字典集</param>
  348. /// <param name="updateValueFactory">更新时的操作</param>
  349. public static void AddOrUpdateTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, NullableConcurrentDictionary<TKey, TValue> that, Func<TKey, TValue, TValue> updateValueFactory)
  350. {
  351. foreach (var item in @this)
  352. {
  353. AddOrUpdate(that, item.Key, item.Value, updateValueFactory);
  354. }
  355. }
  356. /// <summary>
  357. /// 添加或更新键值对
  358. /// </summary>
  359. /// <typeparam name="TKey"></typeparam>
  360. /// <typeparam name="TValue"></typeparam>
  361. /// <param name="this"></param>
  362. /// <param name="that">另一个字典集</param>
  363. /// <param name="updateValueFactory">更新时的操作</param>
  364. public static Task AddOrUpdateAsyncTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, IDictionary<TKey, TValue> that, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  365. {
  366. return @this.ForeachAsync(item => AddOrUpdateAsync(that, item.Key, item.Value, updateValueFactory));
  367. }
  368. /// <summary>
  369. /// 添加或更新键值对
  370. /// </summary>
  371. /// <typeparam name="TKey"></typeparam>
  372. /// <typeparam name="TValue"></typeparam>
  373. /// <param name="this"></param>
  374. /// <param name="that">另一个字典集</param>
  375. /// <param name="updateValueFactory">更新时的操作</param>
  376. public static Task AddOrUpdateAsyncTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, NullableDictionary<TKey, TValue> that, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  377. {
  378. return @this.ForeachAsync(item => AddOrUpdateAsync(that, item.Key, item.Value, updateValueFactory));
  379. }
  380. /// <summary>
  381. /// 添加或更新键值对
  382. /// </summary>
  383. /// <typeparam name="TKey"></typeparam>
  384. /// <typeparam name="TValue"></typeparam>
  385. /// <param name="this"></param>
  386. /// <param name="that">另一个字典集</param>
  387. /// <param name="updateValueFactory">更新时的操作</param>
  388. public static Task AddOrUpdateAsyncTo<TKey, TValue>(this IDictionary<TKey, TValue> @this, NullableConcurrentDictionary<TKey, TValue> that, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  389. {
  390. return @this.ForeachAsync(item => AddOrUpdateAsync(that, item.Key, item.Value, updateValueFactory));
  391. }
  392. /// <summary>
  393. /// 添加或更新键值对
  394. /// </summary>
  395. /// <typeparam name="TKey"></typeparam>
  396. /// <typeparam name="TValue"></typeparam>
  397. /// <param name="this"></param>
  398. /// <param name="key">键</param>
  399. /// <param name="addValueFactory">添加时的操作</param>
  400. /// <param name="updateValueFactory">更新时的操作</param>
  401. public static TValue AddOrUpdate<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, Func<TKey, TValue> addValueFactory, Func<TKey, TValue, TValue> updateValueFactory)
  402. {
  403. if ([email protected](key, addValueFactory(key)))
  404. {
  405. @this[key] = updateValueFactory(key, @this[key]);
  406. }
  407. return @this[key];
  408. }
  409. /// <summary>
  410. /// 添加或更新键值对
  411. /// </summary>
  412. /// <typeparam name="TKey"></typeparam>
  413. /// <typeparam name="TValue"></typeparam>
  414. /// <param name="this"></param>
  415. /// <param name="key">键</param>
  416. /// <param name="addValueFactory">添加时的操作</param>
  417. /// <param name="updateValueFactory">更新时的操作</param>
  418. public static TValue AddOrUpdate<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, TKey key, Func<TKey, TValue> addValueFactory, Func<TKey, TValue, TValue> updateValueFactory)
  419. {
  420. if ([email protected](key, addValueFactory(key)))
  421. {
  422. @this[key] = updateValueFactory(key, @this[key]);
  423. }
  424. return @this[key];
  425. }
  426. /// <summary>
  427. /// 添加或更新键值对
  428. /// </summary>
  429. /// <typeparam name="TKey"></typeparam>
  430. /// <typeparam name="TValue"></typeparam>
  431. /// <param name="this"></param>
  432. /// <param name="key">键</param>
  433. /// <param name="addValueFactory">添加时的操作</param>
  434. /// <param name="updateValueFactory">更新时的操作</param>
  435. public static TValue AddOrUpdate<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, TKey key, Func<TKey, TValue> addValueFactory, Func<TKey, TValue, TValue> updateValueFactory)
  436. {
  437. if ([email protected](key, addValueFactory(key)))
  438. {
  439. @this[key] = updateValueFactory(key, @this[key]);
  440. }
  441. return @this[key];
  442. }
  443. /// <summary>
  444. /// 添加或更新键值对
  445. /// </summary>
  446. /// <typeparam name="TKey"></typeparam>
  447. /// <typeparam name="TValue"></typeparam>
  448. /// <param name="this"></param>
  449. /// <param name="key">键</param>
  450. /// <param name="addValueFactory">添加时的操作</param>
  451. /// <param name="updateValueFactory">更新时的操作</param>
  452. public static async Task<TValue> AddOrUpdateAsync<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, Func<TKey, Task<TValue>> addValueFactory, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  453. {
  454. if ([email protected](key, await addValueFactory(key)))
  455. {
  456. @this[key] = await updateValueFactory(key, @this[key]);
  457. }
  458. return @this[key];
  459. }
  460. /// <summary>
  461. /// 添加或更新键值对
  462. /// </summary>
  463. /// <typeparam name="TKey"></typeparam>
  464. /// <typeparam name="TValue"></typeparam>
  465. /// <param name="this"></param>
  466. /// <param name="key">键</param>
  467. /// <param name="addValueFactory">添加时的操作</param>
  468. /// <param name="updateValueFactory">更新时的操作</param>
  469. public static async Task<TValue> AddOrUpdateAsync<TKey, TValue>(this NullableDictionary<TKey, TValue> @this, TKey key, Func<TKey, Task<TValue>> addValueFactory, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  470. {
  471. if ([email protected](key, await addValueFactory(key)))
  472. {
  473. @this[key] = await updateValueFactory(key, @this[key]);
  474. }
  475. return @this[key];
  476. }
  477. /// <summary>
  478. /// 添加或更新键值对
  479. /// </summary>
  480. /// <typeparam name="TKey"></typeparam>
  481. /// <typeparam name="TValue"></typeparam>
  482. /// <param name="this"></param>
  483. /// <param name="key">键</param>
  484. /// <param name="addValueFactory">添加时的操作</param>
  485. /// <param name="updateValueFactory">更新时的操作</param>
  486. public static async Task<TValue> AddOrUpdateAsync<TKey, TValue>(this NullableConcurrentDictionary<TKey, TValue> @this, TKey key, Func<TKey, Task<TValue>> addValueFactory, Func<TKey, TValue, Task<TValue>> updateValueFactory)
  487. {
  488. if ([email protected](key, await addValueFactory(key)))
  489. {
  490. @this[key] = await updateValueFactory(key, @this[key]);
  491. }
  492. return @this[key];
  493. }
  494. /// <summary>
  495. /// 获取或添加
  496. /// </summary>
  497. /// <typeparam name="TKey"></typeparam>
  498. /// <typeparam name="TValue"></typeparam>
  499. /// <param name="this"></param>
  500. /// <param name="key"></param>
  501. /// <param name="addValueFactory"></param>
  502. public static TValue GetOrAdd<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, Func<TValue> addValueFactory)
  503. {
  504. if ([email protected](key))
  505. {
  506. @this[key] = addValueFactory();
  507. }
  508. return @this[key];
  509. }
  510. /// <summary>
  511. /// 获取或添加
  512. /// </summary>
  513. /// <typeparam name="TKey"></typeparam>
  514. /// <typeparam name="TValue"></typeparam>
  515. /// <param name="this"></param>
  516. /// <param name="key"></param>
  517. /// <param name="addValueFactory"></param>
  518. public static async Task<TValue> GetOrAddAsync<TKey, TValue>(this IDictionary<TKey, TValue> @this, TKey key, Func<Task<TValue>> addValueFactory)
  519. {
  520. if ([email protected](key))
  521. {
  522. @this[key] = await addValueFactory();
  523. }
  524. return @this[key];
  525. }
  526. /// <summary>
  527. /// 获取或添加
  528. /// </summary>
  529. /// <typeparam name="TKey"></typeparam>
  530. /// <typeparam name="TValue"></typeparam>
  531. /// <param name="this"></param>
  532. /// <param name="key"></param>
  533. /// <param name="addValue"></param>
  534. public static TValue GetOrAdd<TKey, TValue>(this Dictionary<TKey, TValue> @this, TKey key, TValue addValue)
  535. {
  536. return @this.TryAdd(key, addValue) ? addValue : @this[key];
  537. }
  538. #if NETSTANDARD2_1_OR_GREATER
  539. #else
  540. public static bool TryAdd<TKey, TValue>(this IDictionary<TKey, TValue> dictionary, TKey key, TValue value) where TKey : notnull
  541. {
  542. if (dictionary == null)
  543. throw new ArgumentNullException(nameof(dictionary));
  544. if (dictionary.IsReadOnly||dictionary.ContainsKey(key))
  545. return false;
  546. dictionary.Add(key, value);
  547. return true;
  548. }
  549. #endif
  550. /// <summary>
  551. /// 遍历IEnumerable
  552. /// </summary>
  553. /// <param name="dic"></param>
  554. /// <param name="action">回调方法</param>
  555. public static void ForEach<TKey, TValue>(this IDictionary<TKey, TValue> dic, Action<TKey, TValue> action)
  556. {
  557. foreach (var item in dic)
  558. {
  559. action(item.Key, item.Value);
  560. }
  561. }
  562. /// <summary>
  563. /// 遍历IDictionary
  564. /// </summary>
  565. /// <param name="dic"></param>
  566. /// <param name="action">回调方法</param>
  567. public static Task ForEachAsync<TKey, TValue>(this IDictionary<TKey, TValue> dic, Func<TKey, TValue, Task> action)
  568. {
  569. return dic.ForeachAsync(x => action(x.Key, x.Value));
  570. }
  571. /// <summary>
  572. /// 安全的转换成字典集
  573. /// </summary>
  574. /// <typeparam name="TSource"></typeparam>
  575. /// <typeparam name="TKey"></typeparam>
  576. /// <param name="source"></param>
  577. /// <param name="keySelector">键选择器</param>
  578. public static NullableDictionary<TKey, TSource> ToDictionarySafety<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
  579. {
  580. var items = source as IList<TSource> ?? source.ToList();
  581. var dic = new NullableDictionary<TKey, TSource>(items.Count);
  582. foreach (var item in items)
  583. {
  584. dic[keySelector(item)] = item;
  585. }
  586. return dic;
  587. }
  588. /// <summary>
  589. /// 安全的转换成字典集
  590. /// </summary>
  591. /// <typeparam name="TSource"></typeparam>
  592. /// <typeparam name="TKey"></typeparam>
  593. /// <param name="source"></param>
  594. /// <param name="keySelector">键选择器</param>
  595. /// <param name="defaultValue">键未找到时的默认值</param>
  596. public static NullableDictionary<TKey, TSource> ToDictionarySafety<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, TSource defaultValue)
  597. {
  598. var items = source as IList<TSource> ?? source.ToList();
  599. var dic = new NullableDictionary<TKey, TSource>(items.Count)
  600. {
  601. FallbackValue = defaultValue
  602. };
  603. foreach (var item in items)
  604. {
  605. dic[keySelector(item)] = item;
  606. }
  607. return dic;
  608. }
  609. /// <summary>
  610. /// 安全的转换成字典集
  611. /// </summary>
  612. /// <typeparam name="TSource"></typeparam>
  613. /// <typeparam name="TKey"></typeparam>
  614. /// <typeparam name="TElement"></typeparam>
  615. /// <param name="source"></param>
  616. /// <param name="keySelector">键选择器</param>
  617. /// <param name="elementSelector">值选择器</param>
  618. public static NullableDictionary<TKey, TElement> ToDictionarySafety<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector)
  619. {
  620. var items = source as IList<TSource> ?? source.ToList();
  621. var dic = new NullableDictionary<TKey, TElement>(items.Count);
  622. foreach (var item in items)
  623. {
  624. dic[keySelector(item)] = elementSelector(item);
  625. }
  626. return dic;
  627. }
  628. /// <summary>
  629. /// 安全的转换成字典集
  630. /// </summary>
  631. /// <typeparam name="TSource"></typeparam>
  632. /// <typeparam name="TKey"></typeparam>
  633. /// <typeparam name="TElement"></typeparam>
  634. /// <param name="source"></param>
  635. /// <param name="keySelector">键选择器</param>
  636. /// <param name="elementSelector">值选择器</param>
  637. /// <param name="defaultValue">键未找到时的默认值</param>
  638. public static NullableDictionary<TKey, TElement> ToDictionarySafety<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, TElement defaultValue)
  639. {
  640. var items = source as IList<TSource> ?? source.ToList();
  641. var dic = new NullableDictionary<TKey, TElement>(items.Count)
  642. {
  643. FallbackValue = defaultValue
  644. };
  645. foreach (var item in items)
  646. {
  647. dic[keySelector(item)] = elementSelector(item);
  648. }
  649. return dic;
  650. }
  651. /// <summary>
  652. /// 安全的转换成字典集
  653. /// </summary>
  654. /// <typeparam name="TSource"></typeparam>
  655. /// <typeparam name="TKey"></typeparam>
  656. /// <typeparam name="TElement"></typeparam>
  657. /// <param name="source"></param>
  658. /// <param name="keySelector">键选择器</param>
  659. /// <param name="elementSelector">值选择器</param>
  660. public static async Task<NullableDictionary<TKey, TElement>> ToDictionarySafetyAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector)
  661. {
  662. var items = source as IList<TSource> ?? source.ToList();
  663. var dic = new NullableDictionary<TKey, TElement>(items.Count);
  664. await items.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  665. return dic;
  666. }
  667. /// <summary>
  668. /// 安全的转换成字典集
  669. /// </summary>
  670. /// <typeparam name="TSource"></typeparam>
  671. /// <typeparam name="TKey"></typeparam>
  672. /// <typeparam name="TElement"></typeparam>
  673. /// <param name="source"></param>
  674. /// <param name="keySelector">键选择器</param>
  675. /// <param name="elementSelector">值选择器</param>
  676. /// <param name="defaultValue">键未找到时的默认值</param>
  677. public static async Task<NullableDictionary<TKey, TElement>> ToDictionarySafetyAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector, TElement defaultValue)
  678. {
  679. var items = source as IList<TSource> ?? source.ToList();
  680. var dic = new NullableDictionary<TKey, TElement>(items.Count)
  681. {
  682. FallbackValue = defaultValue
  683. };
  684. await items.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  685. return dic;
  686. }
  687. /// <summary>
  688. /// 安全的转换成字典集
  689. /// </summary>
  690. /// <typeparam name="TSource"></typeparam>
  691. /// <typeparam name="TKey"></typeparam>
  692. /// <param name="source"></param>
  693. /// <param name="keySelector">键选择器</param>
  694. public static DisposableDictionary<TKey, TSource> ToDisposableDictionarySafety<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector) where TSource : IDisposable
  695. {
  696. var items = source as IList<TSource> ?? source.ToList();
  697. var dic = new DisposableDictionary<TKey, TSource>(items.Count);
  698. foreach (var item in items)
  699. {
  700. dic[keySelector(item)] = item;
  701. }
  702. return dic;
  703. }
  704. /// <summary>
  705. /// 安全的转换成字典集
  706. /// </summary>
  707. /// <typeparam name="TSource"></typeparam>
  708. /// <typeparam name="TKey"></typeparam>
  709. /// <param name="source"></param>
  710. /// <param name="keySelector">键选择器</param>
  711. /// <param name="defaultValue">键未找到时的默认值</param>
  712. public static DisposableDictionary<TKey, TSource> ToDisposableDictionarySafety<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, TSource defaultValue) where TSource : IDisposable
  713. {
  714. var items = source as IList<TSource> ?? source.ToList();
  715. var dic = new DisposableDictionary<TKey, TSource>(items.Count)
  716. {
  717. FallbackValue = defaultValue
  718. };
  719. foreach (var item in items)
  720. {
  721. dic[keySelector(item)] = item;
  722. }
  723. return dic;
  724. }
  725. /// <summary>
  726. /// 安全的转换成字典集
  727. /// </summary>
  728. /// <typeparam name="TSource"></typeparam>
  729. /// <typeparam name="TKey"></typeparam>
  730. /// <typeparam name="TElement"></typeparam>
  731. /// <param name="source"></param>
  732. /// <param name="keySelector">键选择器</param>
  733. /// <param name="elementSelector">值选择器</param>
  734. public static DisposableDictionary<TKey, TElement> ToDisposableDictionarySafety<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector) where TElement : IDisposable
  735. {
  736. var items = source as IList<TSource> ?? source.ToList();
  737. var dic = new DisposableDictionary<TKey, TElement>(items.Count);
  738. foreach (var item in items)
  739. {
  740. dic[keySelector(item)] = elementSelector(item);
  741. }
  742. return dic;
  743. }
  744. /// <summary>
  745. /// 安全的转换成字典集
  746. /// </summary>
  747. /// <typeparam name="TSource"></typeparam>
  748. /// <typeparam name="TKey"></typeparam>
  749. /// <typeparam name="TElement"></typeparam>
  750. /// <param name="source"></param>
  751. /// <param name="keySelector">键选择器</param>
  752. /// <param name="elementSelector">值选择器</param>
  753. /// <param name="defaultValue">键未找到时的默认值</param>
  754. public static DisposableDictionary<TKey, TElement> ToDisposableDictionarySafety<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, TElement defaultValue) where TElement : IDisposable
  755. {
  756. var items = source as IList<TSource> ?? source.ToList();
  757. var dic = new DisposableDictionary<TKey, TElement>(items.Count)
  758. {
  759. FallbackValue = defaultValue
  760. };
  761. foreach (var item in items)
  762. {
  763. dic[keySelector(item)] = elementSelector(item);
  764. }
  765. return dic;
  766. }
  767. /// <summary>
  768. /// 安全的转换成字典集
  769. /// </summary>
  770. /// <typeparam name="TSource"></typeparam>
  771. /// <typeparam name="TKey"></typeparam>
  772. /// <typeparam name="TElement"></typeparam>
  773. /// <param name="source"></param>
  774. /// <param name="keySelector">键选择器</param>
  775. /// <param name="elementSelector">值选择器</param>
  776. public static async Task<DisposableDictionary<TKey, TElement>> ToDisposableDictionarySafetyAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector) where TElement : IDisposable
  777. {
  778. var items = source as IList<TSource> ?? source.ToList();
  779. var dic = new DisposableDictionary<TKey, TElement>(items.Count);
  780. await items.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  781. return dic;
  782. }
  783. /// <summary>
  784. /// 安全的转换成字典集
  785. /// </summary>
  786. /// <typeparam name="TSource"></typeparam>
  787. /// <typeparam name="TKey"></typeparam>
  788. /// <typeparam name="TElement"></typeparam>
  789. /// <param name="source"></param>
  790. /// <param name="keySelector">键选择器</param>
  791. /// <param name="elementSelector">值选择器</param>
  792. /// <param name="defaultValue">键未找到时的默认值</param>
  793. public static async Task<DisposableDictionary<TKey, TElement>> ToDisposableDictionarySafetyAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector, TElement defaultValue) where TElement : IDisposable
  794. {
  795. var items = source as IList<TSource> ?? source.ToList();
  796. var dic = new DisposableDictionary<TKey, TElement>(items.Count)
  797. {
  798. FallbackValue = defaultValue
  799. };
  800. await items.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  801. return dic;
  802. }
  803. /// <summary>
  804. /// 安全的转换成字典集
  805. /// </summary>
  806. /// <typeparam name="TSource"></typeparam>
  807. /// <typeparam name="TKey"></typeparam>
  808. /// <param name="source"></param>
  809. /// <param name="keySelector">键选择器</param>
  810. public static NullableConcurrentDictionary<TKey, TSource> ToConcurrentDictionary<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
  811. {
  812. var dic = new NullableConcurrentDictionary<TKey, TSource>();
  813. foreach (var item in source)
  814. {
  815. dic[keySelector(item)] = item;
  816. }
  817. return dic;
  818. }
  819. /// <summary>
  820. /// 安全的转换成字典集
  821. /// </summary>
  822. /// <typeparam name="TSource"></typeparam>
  823. /// <typeparam name="TKey"></typeparam>
  824. /// <param name="source"></param>
  825. /// <param name="keySelector">键选择器</param>
  826. /// <param name="defaultValue">键未找到时的默认值</param>
  827. public static NullableConcurrentDictionary<TKey, TSource> ToConcurrentDictionary<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, TSource defaultValue)
  828. {
  829. var dic = new NullableConcurrentDictionary<TKey, TSource>()
  830. {
  831. FallbackValue = defaultValue
  832. };
  833. foreach (var item in source)
  834. {
  835. dic[keySelector(item)] = item;
  836. }
  837. return dic;
  838. }
  839. /// <summary>
  840. /// 安全的转换成字典集
  841. /// </summary>
  842. /// <typeparam name="TSource"></typeparam>
  843. /// <typeparam name="TKey"></typeparam>
  844. /// <typeparam name="TElement"></typeparam>
  845. /// <param name="source"></param>
  846. /// <param name="keySelector">键选择器</param>
  847. /// <param name="elementSelector">值选择器</param>
  848. public static NullableConcurrentDictionary<TKey, TElement> ToConcurrentDictionary<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector)
  849. {
  850. var dic = new NullableConcurrentDictionary<TKey, TElement>();
  851. foreach (var item in source)
  852. {
  853. dic[keySelector(item)] = elementSelector(item);
  854. }
  855. return dic;
  856. }
  857. /// <summary>
  858. /// 安全的转换成字典集
  859. /// </summary>
  860. /// <typeparam name="TSource"></typeparam>
  861. /// <typeparam name="TKey"></typeparam>
  862. /// <typeparam name="TElement"></typeparam>
  863. /// <param name="source"></param>
  864. /// <param name="keySelector">键选择器</param>
  865. /// <param name="elementSelector">值选择器</param>
  866. /// <param name="defaultValue"></param>
  867. public static NullableConcurrentDictionary<TKey, TElement> ToConcurrentDictionary<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, TElement defaultValue)
  868. {
  869. var dic = new NullableConcurrentDictionary<TKey, TElement>()
  870. {
  871. FallbackValue = defaultValue
  872. };
  873. foreach (var item in source)
  874. {
  875. dic[keySelector(item)] = elementSelector(item);
  876. }
  877. return dic;
  878. }
  879. /// <summary>
  880. /// 安全的转换成字典集
  881. /// </summary>
  882. /// <typeparam name="TSource"></typeparam>
  883. /// <typeparam name="TKey"></typeparam>
  884. /// <typeparam name="TElement"></typeparam>
  885. /// <param name="source"></param>
  886. /// <param name="keySelector">键选择器</param>
  887. /// <param name="elementSelector">值选择器</param>
  888. public static async Task<NullableConcurrentDictionary<TKey, TElement>> ToConcurrentDictionaryAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector)
  889. {
  890. var dic = new ConcurrentDictionary<TKey, TElement>();
  891. await source.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  892. return dic;
  893. }
  894. /// <summary>
  895. /// 安全的转换成字典集
  896. /// </summary>
  897. /// <typeparam name="TSource"></typeparam>
  898. /// <typeparam name="TKey"></typeparam>
  899. /// <typeparam name="TElement"></typeparam>
  900. /// <param name="source"></param>
  901. /// <param name="keySelector">键选择器</param>
  902. /// <param name="elementSelector">值选择器</param>
  903. /// <param name="defaultValue">键未找到时的默认值</param>
  904. public static async Task<NullableConcurrentDictionary<TKey, TElement>> ToConcurrentDictionaryAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector, TElement defaultValue)
  905. {
  906. var dic = new NullableConcurrentDictionary<TKey, TElement>
  907. {
  908. FallbackValue = defaultValue
  909. };
  910. await source.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  911. return dic;
  912. }
  913. /// <summary>
  914. /// 安全的转换成字典集
  915. /// </summary>
  916. /// <typeparam name="TSource"></typeparam>
  917. /// <typeparam name="TKey"></typeparam>
  918. /// <param name="source"></param>
  919. /// <param name="keySelector">键选择器</param>
  920. public static DisposableConcurrentDictionary<TKey, TSource> ToDisposableConcurrentDictionary<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector) where TSource : IDisposable
  921. {
  922. var dic = new DisposableConcurrentDictionary<TKey, TSource>();
  923. foreach (var item in source)
  924. {
  925. dic[keySelector(item)] = item;
  926. }
  927. return dic;
  928. }
  929. /// <summary>
  930. /// 安全的转换成字典集
  931. /// </summary>
  932. /// <param name="source"></param>
  933. /// <param name="keySelector">键选择器</param>
  934. /// <param name="defaultValue">键未找到时的默认值</param>
  935. public static DisposableConcurrentDictionary<TKey, TSource> ToDisposableConcurrentDictionary<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, TSource defaultValue) where TSource : IDisposable
  936. {
  937. var dic = new DisposableConcurrentDictionary<TKey, TSource>
  938. {
  939. FallbackValue = defaultValue
  940. };
  941. foreach (var item in source)
  942. {
  943. dic[keySelector(item)] = item;
  944. }
  945. return dic;
  946. }
  947. /// <summary>
  948. /// 安全的转换成字典集
  949. /// </summary>
  950. /// <param name="source"></param>
  951. /// <param name="keySelector">键选择器</param>
  952. /// <param name="elementSelector">值选择器</param>
  953. public static DisposableConcurrentDictionary<TKey, TElement> ToDisposableConcurrentDictionary<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector) where TElement : IDisposable
  954. {
  955. var dic = new DisposableConcurrentDictionary<TKey, TElement>();
  956. foreach (var item in source)
  957. {
  958. dic[keySelector(item)] = elementSelector(item);
  959. }
  960. return dic;
  961. }
  962. /// <summary>
  963. /// 安全的转换成字典集
  964. /// </summary>
  965. /// <param name="source"></param>
  966. /// <param name="keySelector">键选择器</param>
  967. /// <param name="elementSelector">值选择器</param>
  968. /// <param name="defaultValue"></param>
  969. public static DisposableConcurrentDictionary<TKey, TElement> ToDisposableConcurrentDictionary<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, TElement defaultValue) where TElement : IDisposable
  970. {
  971. var dic = new DisposableConcurrentDictionary<TKey, TElement>()
  972. {
  973. FallbackValue = defaultValue
  974. };
  975. foreach (var item in source)
  976. {
  977. dic[keySelector(item)] = elementSelector(item);
  978. }
  979. return dic;
  980. }
  981. /// <summary>
  982. /// 安全的转换成字典集
  983. /// </summary>
  984. /// <param name="source"></param>
  985. /// <param name="keySelector">键选择器</param>
  986. /// <param name="elementSelector">值选择器</param>
  987. public static async Task<DisposableConcurrentDictionary<TKey, TElement>> ToDisposableConcurrentDictionaryAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector) where TElement : IDisposable
  988. {
  989. var dic = new DisposableConcurrentDictionary<TKey, TElement>();
  990. await source.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  991. return dic;
  992. }
  993. /// <summary>
  994. /// 安全的转换成字典集
  995. /// </summary>
  996. /// <param name="source"></param>
  997. /// <param name="keySelector">键选择器</param>
  998. /// <param name="elementSelector">值选择器</param>
  999. /// <param name="defaultValue">键未找到时的默认值</param>
  1000. public static async Task<DisposableConcurrentDictionary<TKey, TElement>> ToDisposableConcurrentDictionaryAsync<TSource, TKey, TElement>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, Task<TElement>> elementSelector, TElement defaultValue) where TElement : IDisposable
  1001. {
  1002. var dic = new DisposableConcurrentDictionary<TKey, TElement>()
  1003. {
  1004. FallbackValue = defaultValue
  1005. };
  1006. await source.ForeachAsync(async item => dic[keySelector(item)] = await elementSelector(item));
  1007. return dic;
  1008. }
  1009. /// <summary>
  1010. /// 转换成并发字典集合
  1011. /// </summary>
  1012. public static NullableConcurrentDictionary<TKey, TValue> AsConcurrentDictionary<TKey, TValue>(this Dictionary<TKey, TValue> dic) => dic;
  1013. /// <summary>
  1014. /// 转换成并发字典集合
  1015. /// </summary>
  1016. /// <param name="dic"></param>
  1017. /// <param name="defaultValue">键未找到时的默认值</param>
  1018. public static NullableConcurrentDictionary<TKey, TValue> AsConcurrentDictionary<TKey, TValue>(this Dictionary<TKey, TValue> dic, TValue defaultValue)
  1019. {
  1020. var nullableDictionary = new NullableConcurrentDictionary<TKey, TValue>()
  1021. {
  1022. FallbackValue = defaultValue
  1023. };
  1024. foreach (var p in dic)
  1025. {
  1026. nullableDictionary[p.Key] = p.Value;
  1027. }
  1028. return nullableDictionary;
  1029. }
  1030. /// <summary>
  1031. /// 转换成普通字典集合
  1032. /// </summary>
  1033. public static NullableDictionary<TKey, TValue> AsDictionary<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> dic) => dic;
  1034. /// <summary>
  1035. /// 转换成普通字典集合
  1036. /// </summary>
  1037. /// <param name="dic"></param>
  1038. /// <param name="defaultValue">键未找到时的默认值</param>
  1039. public static NullableDictionary<TKey, TValue> AsDictionary<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> dic, TValue defaultValue)
  1040. {
  1041. var nullableDictionary = new NullableDictionary<TKey, TValue>()
  1042. {
  1043. FallbackValue = defaultValue
  1044. };
  1045. foreach (var p in dic)
  1046. {
  1047. nullableDictionary[p.Key] = p.Value;
  1048. }
  1049. return nullableDictionary;
  1050. }
  1051. }
  1052. }