Java——使用多线程模拟真实高并发业务并保证安全性(二)

简介: Java——使用多线程模拟真实高并发业务并保证安全性(二)

前言

兄弟篇: Java——使用多线程模拟真实高并发业务并保证安全性(一)

一、需求

使用100个线程把一个存放10000条数据的list数据删除,要求保证安全性,并正确记录数量。


二、实现

在看下面的代码之前,读者朋友可以自己先试一试怎么实现上面的需求,然后跟本文的实现方式对比一下。

2.1 使用技术

可重入锁ReentrantReadWriteLock,这里没有使用到CopyOnWriteArrayList,因为ReentrantReadWriteLock已经起到了CopyOnWriteArrayList对容器remove的安全性的同等作用,另外还有对num--的保护。


2.2 实现代码

package com.han.test;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class TestMultiThread2 {
    static List<Integer> list = new ArrayList<Integer>();
    static ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    static int num = 10000;
    static Random random = new Random();
    public static void main(String[] args) {
        // 使用10000作为测试范围,可以根据需要设置数量
        for (int i = 1; i <= 10000; i++) {
            list.add(i);
        }
        System.out.println("list size: " + list.size());
        // 使用10个线程模拟业务,可以根据需要增加或者减少线程数量
        for (int i = 0; i < 100; i++) {
            new Thread() {
                @Override
                public void run() {
                    try {
                        dosomething();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                };
            }.start();
        }
    }
    public static void dosomething() throws InterruptedException {
        // 设置每个线程最多处理100个数据
        int max = 100;
        for (int i = list.size(); list.size() > 0; i--) {
            if (max <= 0) {
                break;
            }
            readWriteLock.writeLock().lock();
            if (list.contains(i)) {
                Thread.sleep(random.nextInt(5));
                list.remove(i - 1);
                num--;
                max--;
                System.out.println(Thread.currentThread().getName() + "***剩余" + num + "个,list数量:" + list.size());
            }
            readWriteLock.writeLock().unlock();
        }
    }
}
相关文章
|
9月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
432 1
|
9月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
401 1
|
10月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
Java 数据库 Spring
449 0
|
10月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
622 16
|
11月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程,涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案,助你掌握高性能并发编程技巧,应对多线程开发中的挑战。
|
11月前
|
数据采集 存储 前端开发
Java爬虫性能优化:多线程抓取JSP动态数据实践
Java爬虫性能优化:多线程抓取JSP动态数据实践
|
Java API 调度
从阻塞到畅通:Java虚拟线程开启并发新纪元
从阻塞到畅通:Java虚拟线程开启并发新纪元
528 83
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
481 0
|
存储 SQL 缓存
Java高并发秒杀系统【观后总结】(四)
在慕课网上发现了一个JavaWeb项目,内容讲的是高并发秒杀,觉得挺有意思的,就进去学习了一番。
501 0
Java高并发秒杀系统【观后总结】(四)