From 32b5de4af771edfaa67197808882512ca7e30120 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Wed, 14 Oct 2020 11:41:01 +0800
Subject: [PATCH] ROC交易所交易问题修复
---
src/test/java/com/xcong/excoin/TradeTest.java | 37 +++++++++++++++++++++++++++++++++++++
1 files changed, 37 insertions(+), 0 deletions(-)
diff --git a/src/test/java/com/xcong/excoin/TradeTest.java b/src/test/java/com/xcong/excoin/TradeTest.java
index b517349..c941e4b 100644
--- a/src/test/java/com/xcong/excoin/TradeTest.java
+++ b/src/test/java/com/xcong/excoin/TradeTest.java
@@ -5,6 +5,7 @@
import com.xcong.excoin.modules.coin.service.OrderCoinService;
import com.xcong.excoin.trade.CoinTrader;
import com.xcong.excoin.utils.RedisUtils;
+import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@@ -13,6 +14,7 @@
import java.math.BigDecimal;
import java.text.ParseException;
import java.util.ArrayList;
+import java.util.Iterator;
import java.util.List;
@Slf4j
@@ -31,4 +33,39 @@
public void buy(){
redisUtils.set("ROC_NEW_PRICE",new BigDecimal("12.33"));
}
+
+ public static void main(String[] args) throws InterruptedException {
+ // 测试两个地方
+ List<String> list = new ArrayList<>();
+ list.add("1");
+ list.add("2");
+ list.add("3");
+ list.add("4");
+ // 开一个线程
+ Thread thread = new Thread(new Runnable() {
+ @SneakyThrows
+ @Override
+ public void run() {
+ Thread.sleep(1000);
+ synchronized (list){
+ Iterator<String> iterator = list.iterator();
+ while (iterator.hasNext()){
+ System.out.println("线程里"+iterator.next());
+ iterator.remove();
+ }
+ }
+
+ }
+ });
+ thread.start();
+ synchronized (list){
+ Iterator<String> iterator = list.iterator();
+ while (iterator.hasNext()){
+ Thread.sleep(1000);
+ System.out.println(iterator.next());
+ }
+ }
+
+ //
+ }
}
--
Gitblit v1.9.1