MCPcopy Create free account
hub / github.com/e2wugui/zeze / process

Method process

ZezeJava/ZezeJavaTest/src/Infinite/Tasks.java:294–319  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

292 }
293
294 @Override
295 long process() {
296 var it = Keys.iterator();
297 long k1, k2;
298 if (Random.getInstance().nextBoolean()) { // random swap
299 k1 = it.next();
300 k2 = it.next();
301 } else {
302 k2 = it.next();
303 k1 = it.next();
304 }
305 var v1 = App.demo_Module1.getTflush().getOrAdd(k1);
306 var v2 = App.demo_Module1.getTflush().getOrAdd(k2);
307 var m1 = v1.getInt_1();
308 var m2 = v2.getInt_1();
309 var money = Random.getInstance().nextInt(1000);
310 v1.setInt_1(m1 - money);
311 v2.setInt_1(m2 + money);
312 var r1 = v1.getInt_1();
313 var r2 = v2.getInt_1();
314 if (debugTradeSum) {
315 Transaction.whileCommit(() -> Simulate.logger.info("{} --- {}:{}-{}={} {}:{}+{}={}",
316 App.getZeze().getConfig().getServerId(), k1, m1, money, r1, k2, m2, money, r2));
317 }
318 return 0L;
319 }
320
321 @Override
322 void verify() throws Exception {

Callers

nothing calls this directly

Calls 11

getInstanceMethod · 0.95
whileCommitMethod · 0.95
getZezeMethod · 0.95
getTflushMethod · 0.80
nextMethod · 0.65
getServerIdMethod · 0.65
iteratorMethod · 0.45
nextBooleanMethod · 0.45
getOrAddMethod · 0.45
nextIntMethod · 0.45
getConfigMethod · 0.45

Tested by

no test coverage detected