|
@@ -7,6 +7,7 @@ import (
|
|
|
|
|
|
|
|
mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
|
|
mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
|
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
|
|
|
|
|
+ "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
|
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
|
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev1/safe_bool"
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev1/safe_bool"
|
|
|
)
|
|
)
|
|
@@ -76,17 +77,17 @@ func (sf *KChan[T]) Read() core_spec.IResult[T] {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// Limit -- ограничение размера канала.
|
|
// Limit -- ограничение размера канала.
|
|
|
-func (sf *KChan[T]) Limit() int {
|
|
|
|
|
|
|
+func (sf *KChan[T]) Limit() defs.Int {
|
|
|
sf.block.RLock()
|
|
sf.block.RLock()
|
|
|
defer sf.block.RUnlock()
|
|
defer sf.block.RUnlock()
|
|
|
- return len(sf.lstMsg)
|
|
|
|
|
|
|
+ return defs.Int(len(sf.lstMsg))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// Len -- возвращает количество элементов в канале.
|
|
// Len -- возвращает количество элементов в канале.
|
|
|
-func (sf *KChan[T]) Len() int {
|
|
|
|
|
|
|
+func (sf *KChan[T]) Len() defs.Int {
|
|
|
sf.block.RLock()
|
|
sf.block.RLock()
|
|
|
defer sf.block.RUnlock()
|
|
defer sf.block.RUnlock()
|
|
|
- return len(sf.lstMsg)
|
|
|
|
|
|
|
+ return defs.Int(len(sf.lstMsg))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// IsClosed -- возвращает признак закрытия канала.
|
|
// IsClosed -- возвращает признак закрытия канала.
|