safe_int.go 3.2 KB

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