多线程下载网络资源

示例:模拟通过5个线程下载10个网络图片

import java.io.*;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;public class MultiThreadDownloader {private static final int THREAD_POOL_SIZE = 5;//线程池大小private List<String> networkResources = new ArrayList<>();//模拟10个网络资源private static final String downloadPath = "E:/Tmp";//下载目录public void download() throws IOException, ExecutionException, InterruptedException {//记录开始时间LocalDateTime currentTime = LocalDateTime.now();DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");String startTime = currentTime.format(formatter);System.out.println("下载开始时间:" + startTime);List<String> executeResult = new ArrayList<>();//创建线程池,多线程下载ExecutorService executorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE);for(String resource:networkResources) {Future<String> future = executorService.submit(new Callable<String>() {@Overridepublic String call() throws Exception {String fileNameSuffix = resource.substring(resource.lastIndexOf("/") + 1);String fileName = downloadPath + File.separator + fileNameSuffix;//文件名和下载地址保持一致File file = new File(fileName);OutputStream outputStream = null;URL url = null;URLConnection urlConnection = null;InputStream inputStream = null;try {outputStream = new FileOutputStream(file);url = new URL(resource);urlConnection = url.openConnection();inputStream = urlConnection.getInputStream();byte[] bytes = new byte[1024];int len = 0;while ((len = inputStream.read()) != -1) {outputStream.write(bytes,0,len);}} catch (FileNotFoundException | MalformedURLException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally {if(outputStream != null) {try {outputStream.close();} catch (IOException e) {e.printStackTrace();}}}executeResult.add("success");return "success";}});//future.get();//等待线程执行结果}executorService.shutdown();System.out.println(executeResult);//记录结束时间currentTime = LocalDateTime.now();String endTime = currentTime.format(formatter);System.out.println("下载结束时间:" + endTime);}public void initDownLoadTask() {networkResources.add("https://pics5.baidu.com/feed/7aec54e736d12f2e20ef4daf3258436c87356844.jpeg");networkResources.add("https://pics7.baidu.com/feed/0ff41bd5ad6eddc42349d0dd474120f353663396.jpeg");networkResources.add("https://pics5.baidu.com/feed/d53f8794a4c27d1e50c0a932080c3b60dfc4384d.jpeg");networkResources.add("https://pics5.baidu.com/feed/95eef01f3a292df5559aa4dab3c0ca6e36a873a7.jpeg");networkResources.add("https://pic.rmb.bdstatic.com/bjh/news/21bf5f01d0fc4d31e1c49167f92ee023.jpeg");networkResources.add("https://pic.rmb.bdstatic.com/bjh/news/4a11f9b43570c2ef89ea4f0c61c8fb19.jpeg");networkResources.add("https://pics5.baidu.com/feed/e4dde71190ef76c675521117d99b6bf4ae5167a2.png");networkResources.add("https://pics5.baidu.com/feed/342ac65c10385343dae1dbe2d19e2670cb808866.jpeg");networkResources.add("https://pics1.baidu.com/feed/64380cd7912397dd1b012247d50d24b9d1a28793.jpeg");networkResources.add("https://pics7.baidu.com/feed/95eef01f3a292df531693cbf37beca6e35a87314.jpeg");}public static void main(String[] args) throws IOException, ExecutionException, InterruptedException {MultiThreadDownloader downloader = new MultiThreadDownloader();downloader.initDownLoadTask();downloader.download();}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/53506.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Hive和Hbase的区别

Hive 和 HBase 都是 Hadoop 生态系统中的重要组件&#xff0c;它们都能处理大规模数据&#xff0c;但各自有不同的适用场景和设计理念。以下是两者的主要区别&#xff1a; 1. 数据模型 Hive&#xff1a;Hive 类似于传统的关系型数据库 (RDBMS)&#xff0c;以表格形式存储数据…

Linux_kernel移植linux09

一、温故知新 1、分析uboot源码目录 每个目录基本上都会有自己的Makefile进行当前层级目录的编译&#xff0c;最后在整个uboot源码目录中会有一个Makefile文件进行整合&#xff0c;将每一层级编译出的目标文件&#xff0c;整合到一起&#xff0c;链接到一起&#xff0c;最终生成…

Spark MLlib模型训练—文本算法 LDA(Latent Dirichlet Allocation)

Spark MLlib模型训练—文本算法 LDA(Latent Dirichlet Allocation) Latent Dirichlet Allocation(LDA)是一种用于主题建模的生成式概率模型,广泛应用于文本分析和自然语言处理。LDA 的目标是从一组文档中发现潜在的主题,并将每个文档表示为这些主题的概率分布。它通过推断…

vscode从本地安装插件

1. 打开VSCode。 2. 点击左侧菜单中的“扩展”&#xff08;或按CtrlShiftX&#xff09;。 3. 点击“更多操作”&#xff08;三个点&#xff09;> “从VSIX安装”。 4. 选择下载的.vsix文件。 5. 点击“安装”即可安装插件。

传统CV算法——基于Opencv的图像绘制

直线绘制 参数解析&#xff1a; &#xff08;图像矩阵&#xff0c;直线起始坐标&#xff0c; 直线终止坐标、颜色、线条厚度&#xff09; cv2.line()是OpenCV中用于绘制直线的函数。 参数说明&#xff1a;img&#xff1a;要绘制直线的图像矩阵。(100,30)&#xff1a;直线的起…

视频提取字幕的软件有哪些?高效转录用这些

探索视频的奥秘&#xff0c;从字幕开始&#xff01;你是否曾被繁复的字幕处理困扰&#xff0c;渴望有一款简单好用的在线免费软件来轻松解锁字幕提取&#xff1f; 告别手动输入的烦恼&#xff0c;我们为你精选了6款视频字幕提取在线免费软件&#xff0c;它们不仅能一键转录&am…

堆-数组的堆化+优先队列(PriorityQueue)的使用

一、堆 1、什么是堆&#xff1f; 以完全二叉树的形式将元素存储到对应的数组位置上所形成的新数组 2、为什么要将数组变成堆&#xff1f; 当数组中的元素连续多次进行排序时会消耗大量的时间&#xff0c;将数组变成堆后通过堆排序的方式将会消耗更少的时间 二、接口 给堆…

这才是程序猿梦想的终端,赶快动手搞起来

文章目录 目标资源列表安装iTerm2安装oh-my-zsh安装颜色主题查找配置文件将配置内容复制到本地设置iTerm2 安装NERD FONTS下载字体安装设置iTerm2 安装PowerLevel10k修改.zshrc重新加载配置 安装插件下载[语法高亮](#syntaxhighlighting)下载[命令提示](#autosuggestions)配置插…

flink窗口分组数据错乱

文章目录 问题目标解决问题-方案1使用事件时间迟到时间输出幂等 解决问题-方案2 问题 正常的flink 作业运行&#xff0c;带窗口的运行&#xff0c;因为上游业务的影响&#xff0c;导致业务恢复后&#xff0c;积累的kafka 数据瞬时涌到flink 程序里&#xff0c;flink 窗口分钟的…

数据结构与算法02 - 复杂度

1、空间复杂度 空间复杂度指的是临时占用存储空间大小的量度&#xff1b;空间复杂度计算的是变量的个数&#xff0c;也采用大O渐进表示法&#xff1b;由于函数在运行的时候所需要的栈空间&#xff08;存储参数、局部变量、一些寄存器信息等&#xff09;在编译器已经确定好了&a…

Kafka【十二】消费者拉取主题分区的分配策略

【1】消费者组、leader和follower 消费者想要拉取主题分区的数据&#xff0c;首先必须要加入到一个组中。 但是一个组中有多个消费者的话&#xff0c;那么每一个消费者该如何消费呢&#xff0c;是不是像图中一样的消费策略呢&#xff1f;如果是的话&#xff0c;那假设消费者组…

Docker容器创建时,无法访问镜像源:Could not connect to archive.ubuntu.com:80

1.问题描述 当基于dockerfile创建容器时&#xff0c;遇到Could not connect to ...、Failed to fetch ...等异常时&#xff0c;大概原因是没有配置好容器创建所需的镜像源。这里以Ubuntu基础镜像源为例。 dockerfile内容 FROM ubuntu RUN apt update && apt install…

MySQL 锁分类有哪些?一文带你详解!!

MySQL 锁 全局锁全局锁的应用场景全局锁的缺点 表级锁表锁元数据&#xff08;MDL&#xff09;锁MDL 锁的问题 意向锁AUTO-INC 锁 行级锁记录锁&#xff08;Record Lock&#xff09;间隙锁&#xff08;Gap Lock&#xff09;临键锁&#xff08;Next-Key Lock&#xff09;插入意向…

Opencv中的直方图(2)计算图像的直方图函数calcHist()的使用

操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 算法描述 计算一组数组的直方图。 函数 cv::calcHist 计算一个或多个数组的直方图。用于递增直方图bin的元组的元素是从相同位置的相应输入数组中获取的。…

vue多环境配置和打包

件名的后缀来指定它们仅在特定模式下被加载。 .env&#xff1a;所有环境下都会加载的通用配置。 .env.local&#xff1a;本地覆盖配置&#xff0c;不加入版本控制。 .env.[mode]&#xff1a;仅为指定的模式加载的配置文件&#xff0c;例如.env.development、.env.production、…

Cursor是什么?Cursor Pro Plus 如何订阅升级教程

一、Cursor是什么&#xff1f; Cursor 是一个基于 Visual Studio Code&#xff08;VS Code&#xff09;技术构建的高级代码编辑器&#xff0c;专为提高编程效率并更深度地整合 AI 功能而设计。它不仅继承了 VS Code 的强大功能和用户界面&#xff0c;还增加了专门针对 AI 支持…

Agent(智能体)和 MetaGPT,一句话实现整个需求应用代码

前面 2 篇文章&#xff0c;我们使用文生文、文生图和文生音频三个大模型共同实现了图文并茂的儿童绘本故事和绘本故事音频需求&#xff1a; 第一篇 根据主题生成儿童绘本故事&#xff1a;GLM-4-Flash 大模型 API 免费了&#xff0c;手把手构建“儿童绘本”应用实战&#xff08…

Nuxt3入门:过渡效果(第5节)

你好同学&#xff0c;我是沐爸&#xff0c;欢迎点赞、收藏、评论和关注。 Nuxt 利用 Vue 的 <Transition> 组件在页面和布局之间应用过渡效果。 一、页面过渡效果 你可以启用页面过渡效果&#xff0c;以便对所有页面应用自动过渡效果。 nuxt.config.js export defaul…

概率DP (由一道绿题引起的若干问题。目前为一些老题,蒟蒻的尝试学习1.0)

概率DP&#xff1a; 利用动态规划去解决 概率 期望 的题目。 概率DP 求概率&#xff08;采用顺推&#xff09; 从 初始状态推向结果&#xff0c;同一般的DP类似&#xff0c;只是经历了概率论知识的包装。 老题&#xff1a; 添加链接描述 题意&#xff1a; 袋子里有w只白鼠&am…

linux编译器——gcc/g++

1.gcc linux上先要安装&#xff0c; sudo yum install gcc gcc --version 可以查看当前的版本 &#xff0c;我们默认安装的是4.8.5的版本&#xff0c;比较低&#xff0c; gcc test.c -stdc99 可以使他支持更高版本的c标准 -o 可以殖指明生成文件的名字&#xff0c;可以自己…