safe_int.go 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. // package safe_int -- потокобезопасный целое.
  2. package safe_int
  3. import (
  4. "sync"
  5. mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
  6. mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
  7. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
  8. "gitp78su.ipnodns.ru/svi/kern/v4/lev1/kint"
  9. )
  10. // safeInt -- потокобезопасное целое.
  11. type safeInt struct {
  12. sync.RWMutex
  13. val mKs.Int
  14. }
  15. // NewSafeInt -- возвращает новое потокобезопасное целое.
  16. func NewSafeInt(val defs.Int) mKs.ISafeInt {
  17. sf := &safeInt{
  18. val: kint.NewInt(val),
  19. }
  20. return sf
  21. }
  22. // NewSafeIntFromStr -- возвращает новое потокобезопасное целое из строки.
  23. func NewSafeIntFromStr(txtVal defs.ITxtFix) mL0.IResult[mKs.ISafeInt] {
  24. sf := NewSafeInt(0)
  25. res := sf.FromStr(txtVal)
  26. if res.IsErr() {
  27. err := defs.Err("NewSafeIntFromStr(): in parse str(%v), err=\n\t%w", txtVal, res.Err())
  28. return mL0.NewErr[mKs.ISafeInt](err)
  29. }
  30. return mL0.NewOk(sf)
  31. }
  32. // NewSafeIntGetenv -- возвращает новое потокобезопасное целое из окружения.
  33. func NewSafeIntGetenv(env defs.ITxtFix) mL0.IResult[mKs.ISafeInt] {
  34. sf := NewSafeInt(0)
  35. res := sf.Getenv(env)
  36. if res.IsErr() {
  37. err := defs.Err("NewSafeIntGetenv(): in parse env(%v), err=\n\t%w", env, res.Err())
  38. return mL0.NewErr[mKs.ISafeInt](err)
  39. }
  40. return mL0.NewOk(sf)
  41. }
  42. // FromBool -- устанавливает значение из булева значения.
  43. //
  44. func (sf *safeInt) FromBool(val bool) defs.Int {
  45. sf.Lock()
  46. defer sf.Unlock()
  47. return sf.val.FromBool(val)
  48. }
  49. // Get -- возвращает хранимое целое.
  50. //
  51. func (sf *safeInt) Get() defs.Int {
  52. sf.RLock()
  53. defer sf.RUnlock()
  54. return sf.val.Get()
  55. }
  56. // Dec -- уменьшает значение на 1.
  57. func (sf *safeInt) Dec() {
  58. sf.Lock()
  59. defer sf.Unlock()
  60. sf.val.Dec()
  61. }
  62. // Inc -- увеличивает значение на 1.
  63. func (sf *safeInt) Inc() {
  64. sf.Lock()
  65. defer sf.Unlock()
  66. sf.val.Inc()
  67. }
  68. // Set -- устанавливает целое.
  69. func (sf *safeInt) Set(val defs.Int) {
  70. sf.Lock()
  71. defer sf.Unlock()
  72. sf.val.Set(val)
  73. }
  74. // Reset -- сбрасывает целое.
  75. func (sf *safeInt) Reset() {
  76. sf.Lock()
  77. defer sf.Unlock()
  78. sf.val.Reset()
  79. }
  80. // FromStr -- получает число из строки.
  81. func (sf *safeInt) FromStr(txtVal defs.ITxtFix) mL0.IResult[defs.Int] {
  82. sf.Lock()
  83. defer sf.Unlock()
  84. return sf.val.FromStr(txtVal)
  85. }
  86. // FromByte -- получает число из среза байт.
  87. func (sf *safeInt) FromByte(binData []byte) mL0.IResult[defs.Int] {
  88. sf.Lock()
  89. defer sf.Unlock()
  90. return sf.val.FromByte(binData)
  91. }
  92. // ToByte -- конвертирует число в срез байт.
  93. func (sf *safeInt) ToByte() []byte {
  94. sf.RLock()
  95. defer sf.RUnlock()
  96. return sf.val.ToByte()
  97. }
  98. // ToBool -- конвертирует число в bool.
  99. func (sf *safeInt) ToBool() bool {
  100. sf.RLock()
  101. defer sf.RUnlock()
  102. return sf.val.ToBool()
  103. }
  104. // ToStr -- конвертирует число в строку.
  105. func (sf *safeInt) ToStr() defs.ITxtFix {
  106. sf.RLock()
  107. defer sf.RUnlock()
  108. return sf.val.ToStr()
  109. }
  110. // Getenv -- получает значение из окружения.
  111. func (sf *safeInt) Getenv(env defs.ITxtFix) mL0.IResult[defs.Int] {
  112. sf.Lock()
  113. defer sf.Unlock()
  114. return sf.val.Getenv(env)
  115. }