IDictionaryExtensions.cs 44 KB

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