文档建议反馈控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

面试题 -- 如何设计一个线程池

前一段时间在写一门算法课，总算是上线了，以及面试，所以没什么时间写，接下来的时间，应该会讲讲面试准备，刷题的一些东西，面了很多，通过面试的有平安，涂鸦智能，阿里，腾讯微保，虾皮，华为荣耀，微众，当然也有其他不少挂的...以前，我总觉得买一件东西，做一件事，或者从某一个时间节点开始，我的生命就会发生转折，一切就会无比顺利，立马变厉害。但是，事实上并不是如此。我不可能马上变厉害，也不可能一口吃成一个胖子。...提高响应速度：利用已经存在的线程进行处理，少去了创建线程的时间 管理线程可控：线程是稀缺资源，不能无限创建，线程池可以做到统一分配和监控 拓展其他功能：比如定时线程池，可以定时执行任务 需要考虑的点 那线程池设计需要考虑的点...：所有线程停止 TERMINATED：线程池的最后状态 各种状态之间是不一样的，他们的状态之间变化如下： 而维护状态的话，可以用一个变量单独存储，并且需要保证修改时的原子性，在底层操作系统中，对int...取任务和执行任务，对于线程池里面的线程而言，就是一个周而复始的工作，除非它会消亡。 线程有哪些状态？

73330

面试题 -- 如何设计一个线程池

以前，我总觉得的买一件东西，做一件事，或者从某一个时间节点开始，我的生命就会发生转折，一切就会无比顺利，立马变厉害。但是，事实上并不是如此。我不可能马上变厉害，也不可能一口吃成一个胖子。...提高响应速度：利用已经存在的线程进行处理，少去了创建线程的时间 管理线程可控：线程是稀缺资源，不能无限创建，线程池可以做到统一分配和监控 拓展其他功能：比如定时线程池，可以定时执行任务 需要考虑的点 那线程池设计需要考虑的点...：所有线程停止 TERMINATED：线程池的最后状态 各种状态之间是不一样的，他们的状态之间变化如下： [20210619211431.png] 而维护状态的话，可以用一个变量单独存储，并且需要保证修改时的原子性...取任务和执行任务，对于线程池里面的线程而言，就是一个周而复始的工作，除非它会消亡。 线程有哪些状态？...TIMED_WAITING ：超时等待，在指定时间后自动唤醒，返回，不会一直等待 TERMINATED ：线程执行完毕，已经退出。

84000
您找到你想要的搜索结果了吗？
是的
没有找到

Django+Celery学习笔记1——任务队列介绍

你过一段时间只需要拿着这个任务id就可以拿到任务执行结果， 在任务执行ing进行时，你可以继续做其它的事情 　　3、Celery 在执行任务时需要通过一个消息中间件来接收和发送任务消息，以及存储任务结果...broker: 存放任务（依赖RabbitMQ或Redis，进行存储） worker：执行任务 　　Celery特性描述 　　1、方便查看定时任务的执行情况, 如 是否成功, 当前状态, 执行任务花费的时间等...}) 　　支持参数： 　　1、countdown : 等待一段时间再执行 add.apply_async((2,3), countdown=5) 　　2、eta : 定义任务的开始时间. add.apply_async...priority.high', routing_key='web.add', priority=0, exchange='web_exchange') 　　Celery 序列化 　　在客户端和消费者之间传输数据需要...Pickle的好处是简单易用，但是在使用的过程中会有一些坑。当代码发生变动时，已经序列化的对象，反序列化后依然是变更前的代码。

98610

动态 |《机器学习》作者Tom Mitchell：人工智能如何向人类大脑学习？

另外我们在脑科学方面的发展也非常迅猛，在过去十几年的时间里，有很多先进的技术和设备，使得我们可以采用无创或者微创的方法进入到人的大脑，进行毫米级地观察，而且在毫秒内就可以对几千张影像进行分析，观察人脑的活性...不同的情况下，大脑各个区会域进行相应的振荡，因此可以在不同的时间点进行观测，当人们在社交的时候，大脑当中管社交的部分会得到同步的激活，不过有自闭症的人和正常人的状况也不一样。...人工智能与脑科学的结合 所以就出现了这样一个问题：为什么不将两者结合起来呢？在研究方面，无论时脑科学还是人工智能都在进行交叉的研究。...对应芹菜可以看到和芹菜相关联的字数，口味是和芹菜相应的一个关联度；对飞机来说，则会出现很多的动词，可以看到相关的一些词就出现了。...，也会有很高的识别率，也就是说，神经的活动对词义的表达，是用了我们矢量表达法来进行词义解释。

89850

有了Future为什么还要CompletableFuture?

, 判断任务执行是否完毕等 场景描述 主线程让一个子线程去执行任务,子线程可能比较耗时,如果没有实现异步任务执行,主线程只能一直等待 Future 接口支持了异步任务执行之后,子线程开始执行任务的同时,...,提供了转化和组合 CompletionFuture 的方法 它可能代表了一个明确完成 Future,也可能代表一个完成阶段 CompletionStage,它支持在计算完成之后触发一些函数或执行某些动作...实现了 Future 和 CompletionStage 接口 核心的四个静态方法,创建一个异步任务 为什么要不用 new CompletionFuture()方式创建异步任务 API 中说明通过...开始引入了 CompletableFuture,它是 Future 的功能增强版,减少阻塞和轮询, 可以传入回调对象,当异步任务完成或者发生异常时,自动回调对象的回调方法 使用 CompletableFuture...* * @return a result */ T get(); } Summer 先说说 join 和 get 的对比 get 在程序编译时会检查异常,join

9110

【40期】说一下线程池内部工作原理

，也会有corePoolSize个线程在候着等任务。...keepAliveTime：线程的存活时间。当线程池里的线程数大于corePoolSize时，如果等了keepAliveTime时长还没有任务可执行，则线程退出。...handler：拒绝策略，当线程池里线程被耗尽，且队列也满了的时候会调用。 以上就是创建线程池时用到的参数，面试中经常会有面试官问到这个问题。...如果放入workQueue失败，则创建线程执行任务，如果这时创建线程失败(当前线程数不小于maximumPoolSize时)，就会调用reject(内部调用handler)拒绝接受任务。...如果当前线程数大于corePoolSize，则会调用workQueue的poll方法获取任务，超时时间是keepAliveTime。

32020

并行分布式框架 Celery 之架构 (1)

当用户触发的一个操作需要较长时间才能执行完成时，可以把它作为任务交给Celery去异步执行，执行完再返回给用户。这段时间用户不需要等待，提高了网站的整体吞吐量和响应时间。 定时任务。...1.3 特性 Celery提供了如下的特性： 方便地查看定时任务的执行情况，比如执行是否成功、当前状态、执行任务花费的时间等。...0x02 Celery的架构 Celery 的基本逻辑为：分布式异步消息任务队列。 在 Celery 中，采用的是分布式的管理方式，每个节点之间都是通过广播/单播进行通信，从而达到协同效果。...Worker：需要有一个组件来执行任务，这就是 Worker： Worker 需要从 broker 接受任务。...接受任务之后，Worker 需要了解任务，知道怎么执行任务，执行任务。所以有一个问题：Worker 怎么知道 client 端的任务？ 通常会在多台服务器运行多个 worker 来提高执行效率。

66220

基础篇：高并发一瞥，线程和线程池的总结

，必须是继承Thread或者是实现Runnable接口 Thread.sleep与Object.wait区别 Thread.sleep需要指定休眠时间，时间一到继续运行；和锁机制无关，不能加锁也不用释放锁...无任务执行时，会被销毁 3 keepAliveTime：非核心线程在闲暇间的存活时间 4 TimeUnit：和keepAliveTime配合使用，表示keepAliveTime参数的时间单位 5 workQueue...；否，则创建核心线程来执行任务；是，则执行plan B plan B：当任务数大于核心数时，任务被加入阻塞队列，如果超过阻塞队列的容量上限，执行C plan C: 阻塞队列不能接受任务时，且设置的maximumPoolSize...SingleThreadExecutor比new个线程的好处是；「线程运行时抛出异常的时候会有新的线程加入线程池完成接下来的任务；阻塞队列可以保证任务按FIFO执行」 //Executors.java...shuwdown：线程池拒接收新任务，同时等待线程池里的任务执行完毕后关闭线程池，代码和shutdownNow类似就不贴了 10 线程池为什么使用的是阻塞队列 先考虑下为啥线程池的线程不会被释放，它是怎么管理线程的生命周期的呢

56910

彻底理解Java并发：Java线程池

4、线程池状态 RUNNING：这个状态表明线程池处于正常状态，可以处理任务，可以接受任务 SHUTDOWN：这个状态表明线程池处于正常关闭状态，不再接受任务，但是可以处理线程池中剩余的任务...这个线程池只有一个线程在工作，也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束，那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。...和 Future、FutureTask 这几个类 Executor 框架是 Java5 之后引进的，在 Java 5 之后，通过 Executor 来启动线程比使用 Thread 的 start 方法更好...用户无需关注如何创建线程，如何调度线程来执行任务，用户只需提供Runnable对象，将任务的运行逻辑提交到执行器（Executor）中，由Executor框架完成线程的调配和任务的执行部分。...AbstractExecutorService则是上层的抽象类，将执行任务的流程串联了起来，保证下层的实现只需关注一个执行任务的方法即可。

36020

Android Jetpack - 使用 WorkManager 管理后台任务

这也是为什么前面说 WorkManager.getInstance().enqueue(request) 是将任务加入任务队列，并不代表马上执行任务，因为任务可能需要等到满足环境条件的情况才会执行。...强大的生命力 还是一样的代码，我们来做点不一样的操作： 断网后运行 将进程杀掉 联网 再次运行 不出意外的话，这时候你会看到有两个时间的打印，而且两个时间还不一样，这是为什么呢？...除了需要传入间隔时间，使用起来跟 OneTimeWorkRequest 是没有区别的。...你可能会想更频繁的去执行一个任务，比如几秒钟执行一遍，但很遗憾，最小时间间隔就是 15 分钟，看一下源码就知道了。...要是上面有细看的话，你应该已经发现这几点了： 定时任务有最小间隔时间的限制，是 15 分钟 只有程序运行时，任务才会得到执行 无法拉起 Activity 总之，用 WorkManager 保活是不可能了

1.7K70

线程池理念分析及其手写

,就会有大量时间用在创建和销毁上,而不是在执行任务上,而线程池关注的就是调整T1和T3的时间,线程池可以免去T1和T3的时间 　　　　3:提高线程的可管理性 　　不如先来实现一个自己的线程池 　　　　思想...: 　　　　　　1:为了优化T1和T3的时间,在使用前,线程必须在池中已经创建好了,并且可以保持住,既然要保存住,那么就需要一个容器 　　　　　　2:里面的线程如果是只能跑已经在内部写好的代码,那么就没有意义...long keepAliveTime:线程空闲下来的存活时间,这个数值,只有在线程池内的线程数量 > corePoolSize的时候才会有作用,它决定着 > corePoolSize数量的线程的空闲下来的存活时间...　　　　　　　　scheduleWithFixedDelay：提交固定延时间隔执行的任务 　　　　　　两者的区别： ? 　　　　　　　　...　　　　　　　　第一个任务第0秒开始，第80S结束； 　　　　　　　　第二个任务第80s开始，在第100秒结束； 　　　　　　　　第三个任务第120s秒开始，170秒结束 　　　　　　　　第四个任务从

32620

扫盲篇-什么是分布式任务调度

某网站为了实现天气实时展示，每隔5分钟就去天气服务器获取最新的实时天气信息。 以上场景就是任务调度所需要解决的问题。 任务调度是指系统为了自动完成特定任务，在约定的特定时刻去执行任务的过程。...有了任务调度即可解放更多的人力由系统自动去执行任务。 任务调度如何实现？ 多线程方式实现： 学过多线程的同学，可能会想到，我们可以开启一个线程，每sleep一段时间，就去检查是否已到预期执行时间。...} } }; Thread thread = new Thread(runnable); thread.start(); } 上面的代码实现了按一定的间隔时间执行任务调度的功能...Timer 和 ScheduledExecutor 都仅能提供基于开始时间与重复间隔的任务调度，不能胜任更加复杂的调度需求。...Quartz支持简单的按时间间隔调度、还支持按日历调度方式，通过设置CronTrigger表达式（包括：秒、分、时、日、月、周、年）进行任务调度。

4.6K30

爬虫架构|Celery+RabbitMQ快速入门（三）

在之前两章节中，简单介绍了Celery+RabbitMQ，以及它们之间的协作过程（见文章爬虫架构|Celery+RabbitMQ快速入门（一）和爬虫架构|Celery+RabbitMQ快速入门（二））。...它的基本工作就是管理分配任务到不同的服务器，并且取得结果”，可以得知，我们之所以使用它是看中了它的分布式，我们使用的场景也是用它做分布式爬虫架构（为什么不选用scrapy-redis？...以及它们之间的区别，下次再讲）。 对于一个分布式爬虫来说，有两个最基本的问题需要解决。 分配爬取任务：为每个爬虫分配不重复的爬取任务。 汇总爬取结果：将所有爬虫爬取到的数据汇总到一处。...至于多个worker为什么不会出现消费同一个任务，这里是celery本身的负载均衡的机制保障了任务去重。...: 实际执行任务的程序 broker: 接受任务消息，存入队列再按顺序分发给worker执行 backend: 存储结果的服务器 还剩下celery beat和backend没有讲解，后面会有一篇爬虫架构

2K70

【原创】Java并发编程系列35 | ScheduledThreadPoolExecutor定时器

可以返回结果； 第三种scheduleAtFixedRate(); 固定周期执行任务，每次执行的开始时间之间的间隔是固定的，最开始就能够确定之后每次执行的时间； 第四种scheduleWithFixedDelay...(); 固定延时周期执行任务，上一次执行结束到下一次执行开始的间隔时间是固定的，由于每次执行任务花费时间不一定相同，所以只有在上次执行结束之后才能确定下次执行开始的时间。...4. scheduleAtFixedRate() VS scheduleWithFixedDelay() scheduleAtFixedRate(); 固定周期执行任务，每次执行的开始时间之间的间隔是固定的...； 第三种scheduleAtFixedRate(); 固定周期执行任务，每次执行的开始时间之间的间隔是固定的，最开始就能够确定之后每次执行的时间； 第四种scheduleWithFixedDelay(...); 固定延时周期执行任务，上一次执行结束到下一次执行开始的间隔时间是固定的，由于每次执行任务花费时间不一定相同，所以只有在上次执行结束之后才能确定下次执行开始的时间。

77310

爬虫架构|Celery+RabbitMQ快速入门（四）整合版本

worker: 实际执行任务的程序 broker: 接受任务消息，存入队列再按顺序分发给worker执行 backend: 存储结果的服务器了 接下来整合前面三篇文章的内容，做一个整合版本。...一、Celery简介 Celery是一个专注于实时处理和任务调度的分布式任务队列。所谓任务就是消息，消息中的有效载荷中包含要执行任务需要的全部数据。 使用Celery的常见场景如下： Web应用。...当用户触发的一个操作需要较长时间才能执行完成时，可以把它作为任务交给Celery去异步执行，执行完再返回给用户。这段时间用户不需要等待，提高了网站的整体吞吐量和响应时间。 定时任务。...Celery还提供了如下的特性： 方便地查看定时任务的执行情况，比如执行是否成功、当前状态、执行任务花费的时间等。 可以使用功能齐备的管理后台或者命令行添加、更新、删除任务。...四、Celery序列化 在客户端和消费者之间传输数据需要序列化和反序列化，Celery支持如下的序列化方案： pickle pickle是Python标准库中的一个模块，支持Python内置的数据结构

2.1K70

【小家java】Java定时任务ScheduledThreadPoolExecutor详解以及与Timer、TimerTask的区别（执行指定次数停止任务）

Timer和TimerTask 本文先介绍Java最原始的解决方案：Timer和TimerTask Timer和TimerTask可以作为线程实现的第三种方式，在JDK1.3的时候推出。...第三个和第四个方法则属于第二类，即在第二个参数（initialDelay）指定的时间之后开始周期性的执行任务，执行周期间隔为第三个参数指定的时间。...但是这两个方法的区别在于：第三个方法执行任务的间隔是固定的，无论上一个任务是否执行完成（也就是前面的任务执行慢不会影响我后面的执行）。...而第四个方法的执行时间间隔是不固定的，其会在周期任务的上一个任务执行完成之后才开始计时，并在指定时间间隔之后才开始执行任务。...则后面的执行会等待5s才回去执行 scheduleWithFixedDelay 是以上一个任务结束时开始计时，period时间过去后，立即执行, 由上面的运行结果可以看出，第一个任务开始和第二个任务开始的间隔时间是

3.4K20

常见重试方法的交互研究

由于中间没有任何时间间隔，如果所有的客户端都发生这种行为，这会导致服务端爆炸，爆炸代表的是服务器过载和崩溃。然后它会在几秒钟后重新启动。...然后开始继续陷入崩溃的漩涡。 延迟重试 因此，在紧密循环中重试是有问题的，我们已经了解了原因。人们要做的下一件事是在每次重试之间添加延迟。重试 10 次，sleep(1000) 中间间隔 1 次。...但这在实践中会导致糟糕的用户体验。用户不喜欢等待，并且重试之间的睡眠时间越长，他们就越有可能手动刷新或去做其他事情。都是不好的结果。...在计算指数退避时，您可以配置很多东西，但如果您想象我们开始等待 1 秒，每次重试等待两倍的时间，那么 10 次重试将如下所示： 1秒 2秒 4秒 8秒 16秒 32秒 1分4秒 2分8秒 4分16秒 8...抖动 我们已经看到了指数退避的威力，但我们还可以通过重试做最后一件事，使它们成为真正的最佳实践。 “抖动”是将重试之间等待的时间随机化到特定范围内的过程。

13820

django开发傻瓜教程-3-celer

Celery 当前的需求是：我用form从前端拿到了提交的数据，由于需要处理一点时间（也许很多用户同时提请求呢）虽然感觉暂时想多了=.= 如果处理时间过长，那么一方面页面可能会超时，另一方面，用户等待太久也是不合适的...我也考虑过用ajax直接部分刷新页面，但是感觉对于长时间的并发任务，可能不是很合适（看到的ajax例子都是很简单的，不是很懂是不是不适合复杂的计算逻辑？）。总之，为了以后的发展，还是学一下水芹菜吧。...大型任务：执行时间较长的任务，例如视频和图片处理，添加水印和转码等，需要执行任务时间长。 定时执行的任务：支持任务的定时执行和设定时间执行。例如性能压测定时执行。...为了让celery中执行任务的结果返回Django，再装一个 sudo pip install django-celery-results 使用redis做broker和backend，安装： sudo...里（我这里是把design2.py和主页design-post绑在一起的，所以我写到design2.py里去) longtime_test.delay() 补一刀： 在design2.py里，我这么写（

58830
点击加载更多

扫码

添加站长 进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

更多标签

活动推荐

    运营活动

    活动名称
    广告关闭

    腾讯云开发者

    扫码关注腾讯云开发者

    扫码关注腾讯云开发者

    领取腾讯云代金券

    热门产品

    热门推荐

    更多推荐

    Copyright © 2013 - 2024 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有

    深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

    腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287

    领券