下面列出了org.apache.commons.lang.mutable.MutableInt#setValue ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
public List<Map<String,String>> getConnectionPoolStats(MutableInt maxTotal, MutableInt numActive, MutableInt maxIdle, MutableInt numIdle,
MutableInt numWaiting) {
ArrayList<Map<String,String>> t = new ArrayList<>();
// no changes to underlying values while collecting metrics
synchronized (connectorToTrackingMapMap) {
// no changes to underlying values while collecting metrics
synchronized (threadToTrackingMapMap) {
// synchronize this last to prevent race condition for this lock underlying super type
synchronized (this) {
if (!threadToTrackingMapMap.isEmpty()) {
t.addAll(Collections.unmodifiableCollection(threadToTrackingMapMap.values()));
}
if (!connectorToTrackingMapMap.isEmpty()) {
t.addAll(Collections.unmodifiableCollection(connectorToTrackingMapMap.values()));
}
maxTotal.setValue(getMaxTotal());
numActive.setValue(getNumActive());
maxIdle.setValue(getMaxIdle());
numIdle.setValue(getNumIdle());
numWaiting.setValue(getNumWaiters());
}
}
}
return Collections.unmodifiableList(t);
}
private static long readLIBSVMMatrixFromInputStream( InputStream is, String srcInfo, MatrixBlock dest, MutableInt rowPos,
long rlen, long clen, int blen )
throws IOException
{
SparseRowVector vect = new SparseRowVector(1024);
String value = null;
int row = rowPos.intValue();
long lnnz = 0;
// Read the data
try( BufferedReader br = new BufferedReader(new InputStreamReader(is)) ) {
while( (value=br.readLine())!=null ) { //for each line
String rowStr = value.toString().trim();
lnnz += ReaderTextLIBSVM.parseLibsvmRow(rowStr, vect, (int)clen);
dest.appendRow(row, vect);
row++;
}
}
rowPos.setValue(row);
return lnnz;
}
private static long readLIBSVMMatrixFromInputStream( InputStream is, String srcInfo, MatrixBlock dest, MutableInt rowPos,
long rlen, long clen, int blen )
throws IOException
{
SparseRowVector vect = new SparseRowVector(1024);
String value = null;
int row = rowPos.intValue();
long lnnz = 0;
// Read the data
try( BufferedReader br = new BufferedReader(new InputStreamReader(is)) ) {
while( (value=br.readLine())!=null ) { //for each line
String rowStr = value.toString().trim();
lnnz += ReaderTextLIBSVM.parseLibsvmRow(rowStr, vect, (int)clen);
dest.appendRow(row, vect);
row++;
}
}
rowPos.setValue(row);
return lnnz;
}
@Override
public void run() {
//let the players update smoother
int remainingUpdates = getNextUpdates();
for (Map.Entry<Player, MutableInt> entry : queue.entrySet()) {
Player player = entry.getKey();
MutableInt remainingTicks = entry.getValue();
if (remainingTicks.intValue() == 0) {
if (remainingUpdates != 0) {
//Smoother refreshing; limit the updates
plugin.getScoreboardManager().onUpdate(player);
remainingTicks.setValue(20 * Settings.getInterval());
remainingUpdates--;
}
} else {
remainingTicks.decrement();
}
}
nextGlobalUpdate--;
if (nextGlobalUpdate == 0) {
nextGlobalUpdate = 20 * Settings.getInterval();
//update globals
plugin.getReplaceManager().updateGlobals();
}
}
public void addPointsByRace(Race race, int points) {
MutableInt pointsByRace = getPointsByRace(race);
pointsByRace.add(points);
if (pointsByRace.intValue() < 0) {
pointsByRace.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt pvpKillsByRace = getPvpKillsByRace(race);
pvpKillsByRace.add(points);
if (pvpKillsByRace.intValue() < 0) {
pvpKillsByRace.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt racePoints = getPvpKillsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt racePoints = getPvpKillsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt racePoints = getPvpKillsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt racePoints = getPvpKillsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt racePoints = getPvpKillsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPointsByRace(Race race, int points) {
MutableInt racePoints = getPointsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}
public void addPvpKillsByRace(Race race, int points) {
MutableInt racePoints = getPvpKillsByRace(race);
racePoints.add(points);
if (racePoints.intValue() < 0) {
racePoints.setValue(0);
}
}