| | |
| | | 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; |
| | |
| | | import java.math.BigDecimal; |
| | | import java.text.ParseException; |
| | | import java.util.ArrayList; |
| | | import java.util.Iterator; |
| | | import java.util.List; |
| | | |
| | | @Slf4j |
| | |
| | | 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()); |
| | | } |
| | | } |
| | | |
| | | // |
| | | } |
| | | } |