From d5b1ec5dca1aefb6425d2e12b1b2804714019c27 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 28 Jan 2021 16:31:21 +0800
Subject: [PATCH] whole bomb finish
---
src/test/java/com/xcong/excoin/WholeTest.java | 48 ++++++++++++++++++++++++++++++++----------------
1 files changed, 32 insertions(+), 16 deletions(-)
diff --git a/src/test/java/com/xcong/excoin/WholeTest.java b/src/test/java/com/xcong/excoin/WholeTest.java
index a58c732..9d52d39 100644
--- a/src/test/java/com/xcong/excoin/WholeTest.java
+++ b/src/test/java/com/xcong/excoin/WholeTest.java
@@ -18,6 +18,7 @@
import com.xcong.excoin.utils.CalculateUtil;
import com.xcong.excoin.utils.RedisUtils;
import com.xcong.excoin.utils.ThreadPoolUtils;
+import lombok.SneakyThrows;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
@@ -28,6 +29,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
/**
* @author wzy
@@ -116,22 +118,6 @@
CalculateUtil.getForceSetPriceForWhole("BTC/USDT", memberEntity);
}
- @Test
- public void initOrderTest() {
- List<HashMap<String, Object>> wholeHoldOrders = contractHoldOrderDao.selectAllWholeOrderMemberIdAndSymbol();
- if (CollUtil.isNotEmpty(wholeHoldOrders)) {
- MemberEntity memberEntity = null;
- for (HashMap<String, Object> wholeHoldOrder : wholeHoldOrders) {
- Long memberId = (Long) wholeHoldOrder.get("member_id");
- String symbol = (String) wholeHoldOrder.get("symbol");
- if (memberEntity == null || !memberId.equals(memberEntity.getId())) {
- memberEntity = memberDao.selectById(memberId);
- }
- System.out.println(memberId + "-----" + symbol);
- }
- }
- }
-
@Resource
private RedisUtils redisUtils;
@@ -156,6 +142,36 @@
CalculateUtil.getForceSetPriceForWhole(null, memberEntity);
}
+ public static void main(String[] args) {
+ Map<String, String> map = new ConcurrentHashMap<>();
+ map.put("1", "1");
+ map.put("2", "2");
+ map.put("3", "3");
+ map.put("4", "4");
+ map.put("5", "5");
+ new Thread(new Runnable() {
+ @SneakyThrows
+ @Override
+ public void run() {
+ for (Map.Entry<String, String> entry : map.entrySet()) {
+ System.out.println(entry.getKey() + " - " + entry.getValue());
+ if (entry.getKey().equals("3")) {
+ System.out.println(11);
+ map.remove("3");
+ }
+ Thread.sleep(1000);
+ }
+
+ System.out.println(map.get("3"));
+ }
+ }).start();
+
+ }
+
+ @Test
+ public void mapTest() {
+ websocketPriceService.wholeBomb();
+ }
}
--
Gitblit v1.9.1