CreditMap

java.lang.Object
- com.fr.third.jgroups.util.CreditMap

```
public class CreditMap
extends java.lang.Object
```
Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.

作者:

Bela Ban

字段概要

字段
限定符和类型	字段和说明
`protected long`	`accumulated_credits`
`protected Average`	`avg_block_time`
`protected java.util.Map<Address,java.lang.Long>`	`credits`
`protected java.util.concurrent.locks.Condition`	`credits_available`
`protected java.util.concurrent.locks.Lock`	`lock`
`protected long`	`max_credits`
`protected long`	`min_credits`
`protected int`	`num_blockings`

构造器概要

构造器
构造器和说明

CreditMap(long max_credits)

构造器
构造器和说明
`CreditMap(long max_credits)`

方法概要

方法
限定符和类型	方法和说明
`void`	`clear()`
`protected long`	`computeLowestCredit()` Needs to be called with lock held
`long`	`computeLowestCreditWithAccumulated()`
`protected boolean`	`decrement(long credits)`
`boolean`	`decrement(long credits, long timeout)` Decrements credits bytes from all.
`protected void`	`decrementAndAdd(Address member, long new_credits)` Decrements credits bytes from all elements and add new_credits to member (if non null).
`protected void`	`flushAccumulatedCredits()`
`java.lang.Long`	`get(Address member)`
`long`	`getAccumulatedCredits()`
`double`	`getAverageBlockTime()`
`java.util.List<Tuple<Address,java.lang.Long>>`	`getMembersWithCreditsLessThan(long min_credits)`
`java.util.List<Address>`	`getMembersWithInsufficientCredits(long credit_needed)`
`long`	`getMinCredits()`
`int`	`getNumBlockings()`
`java.util.Set<Address>`	`keys()`
`java.lang.Long`	`putIfAbsent(Address key)`
`java.lang.Long`	`remove(Address key)`
`void`	`replenish(Address sender, long new_credits)`
`void`	`replenishAll()`
`void`	`reset()`
`java.lang.String`	`toString()`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

字段详细资料

max_credits
```
protected final long max_credits
```

credits

protected final java.util.Map<Address,java.lang.Long> credits

min_credits
```
protected long min_credits
```

accumulated_credits
```
protected long accumulated_credits
```

lock

protected final java.util.concurrent.locks.Lock lock

credits_available

protected final java.util.concurrent.locks.Condition credits_available

num_blockings
```
protected int num_blockings
```

avg_block_time
```
protected final Average avg_block_time
```

构造器详细资料
- CreditMap
```
public CreditMap(long max_credits)
```

方法详细资料
- getAccumulatedCredits
```
public long getAccumulatedCredits()
```
- getMinCredits
```
public long getMinCredits()
```
- getNumBlockings
```
public int getNumBlockings()
```
- getAverageBlockTime
```
public double getAverageBlockTime()
```
- keys
```
public java.util.Set<Address> keys()
```
- get
```
public java.lang.Long get(Address member)
```
- remove
```
public java.lang.Long remove(Address key)
```
- putIfAbsent
```
public java.lang.Long putIfAbsent(Address key)
```
- getMembersWithInsufficientCredits
```
public java.util.List<Address> getMembersWithInsufficientCredits(long credit_needed)
```
- getMembersWithCreditsLessThan
```
public java.util.List<Tuple<Address,java.lang.Long>> getMembersWithCreditsLessThan(long min_credits)
```
- decrement
```
public boolean decrement(long credits,
                long timeout)
```
  Decrements credits bytes from all. Returns true if successful, or false if not. Blocks for timeout ms (if greater than 0).
  
  参数:
  credits - Number of bytes to decrement from all members
  timeout - Number of milliseconds to wait until more credits have been received
  
  返回:
  True if decrementing credits bytes succeeded, false otherwise
- replenish
```
public void replenish(Address sender,
             long new_credits)
```
- replenishAll
```
public void replenishAll()
```
- clear
```
public void clear()
```
- reset
```
public void reset()
```
- toString
```
public java.lang.String toString()
```
  覆盖:
  
  toString 在类中 java.lang.Object
- decrement
```
protected boolean decrement(long credits)
```
- computeLowestCredit
```
protected long computeLowestCredit()
```
  Needs to be called with lock held
- computeLowestCreditWithAccumulated
```
public long computeLowestCreditWithAccumulated()
```
- decrementAndAdd
```
protected void decrementAndAdd(Address member,
                   long new_credits)
```
  Decrements credits bytes from all elements and add new_credits to member (if non null). The lowest credit needs to be greater than min_credits. Needs to be called with lock held
  
  参数:
  member - The member to which new_credits are added. NOP if null
  new_credits - Number of bytes to add to member. NOP if 0.
- flushAccumulatedCredits
```
protected void flushAccumulatedCredits()
```

类 CreditMap

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

字段详细资料

max_credits

credits

min_credits

accumulated_credits

lock

credits_available

num_blockings

avg_block_time

构造器详细资料

CreditMap

方法详细资料

getAccumulatedCredits

getMinCredits

getNumBlockings

getAverageBlockTime

keys

get

remove

putIfAbsent

getMembersWithInsufficientCredits

getMembersWithCreditsLessThan

decrement

replenish

replenishAll

clear

reset

toString

decrement

computeLowestCredit

computeLowestCreditWithAccumulated

decrementAndAdd

flushAccumulatedCredits