前言 经过前几篇的介绍，对RxJava对模式有了一定的理解：由Observable发起事件，经过中间的处理后由Observer消费。（对RxJava还不了解的可以出门左拐） 之前的代码中，事件的发起和消费都是在同一个线程中执行，也就是说之前我们使用的RxJava是同步的～～～ 观察者模式本身的目的不就是后台处理，将处理结果回调给前台？这同步的是要哪样？所以，这篇为大家介绍RxJava的重要的概念——Scheduler 参考：给 Android 开发者的 RxJava 详解 （本文部分内容引用自该博
在不指定线程的情况下， RxJava 遵循的是线程不变的原则，即：在哪个线程调用 subscribe()，就在哪个线程生产事件；在哪个线程生产事件，就在哪个线程消费事件。如果需要切换线程，就需要用到 Scheduler （调度器）。
threadlist的runcheckpoint方法作用是让所有线程都执行制定的任务。threadlist的dump方法有两种实现方式：
OpenMP是一种用于并行编程的开放标准，它旨在简化共享内存多线程编程的开发过程。OpenMP提供了一组指令和库例程，可以将顺序程序转换为可并行执行的代码。
Monitor和lock是c#语言中多线程应用程序中提供线程安全的方法(lock关键字的本质就是对Monitor的封装)。两者都提供了一种机制来确保只有一个线程同时执行代码，以避免代码功能被其他线程中断
1.HANDLE CreateThread( _In_opt_LPSECURITY_ATTRIBUTES lpThreadAttributes, _In_SIZE_T dwStackSize, _In_LPTHREAD_START_ROUTINE lpStartAddress, _In_opt___drv_aliasesMemLPVOID lpParameter, _In_DWORD dwCreationFlags, _Out_opt_LPDWORD lpThreadId ); 参数说明 lpThreadAttributes：指向SECURITY_ATTRIBUTES型态的结构的指针。在Windows 98中忽略该参数。在Windows NT中，NULL使用默认安全性，不可以被子线程继承，否则需要定义一个结构体将它的bInheritHandle成员初始化为TRUE dwStackSize，设置初始栈的大小，以字节为单位，如果为0，那么默认将使用与调用该函数的线程相同的栈空间大小。任何情况下，Windows根据需要动态延长堆栈的大小。 lpStartAddress，指向线程函数的指针. lpParameter：向线程函数传递的参数，是一个指向结构的指针，不需传递参数时，为NULL。 dwCreationFlags ：线程标志,可取值如下 （1）CREATE_SUSPENDED(0x00000004)：创建一个挂起的线程， （2）0：表示创建后立即激活。
上一节教程讲解了最基本的RxJava2的使用, 在本节中, 我们将学习RxJava强大的线程控制.
接着《图解RxJava2(一)》这一片讲讲在 RxJava 中可以通过 subscribeOn/observeOn 很方便地完成上下游指定线程的切换，日常开发除了一些常用的Rx 操作符外，这两个方法也是打交道最多的。最初学习 RxJava 的时候总是死记硬背：subscribeOn 用于指定上游线程，observeOn 用于指定下游线程，多次用 subscribeOn 指定上游线程只有第一次有效，多次用 observeOn 指定下次线程，每次都有效…很久不用之后，总是把这两个方法搞混，那么这两个方法内部是怎么实现的呢？本篇先分析subscribeOn 方法。
Thread 类是java中的线程类，提供给用户用于创建、操作线程、获取线程的信息的类。是java线程一切的基础，掌握这个类是非常必须的，先来看一下它的API. 1、字段摘要 static int MAX_PRIORITY 线程可以具有的最高优先级 static int MIN_PRIORITY 线程可以具有的最低优先级 static int NORM_PRIORITY 分配给线程的默认优先级 2、构造方法摘要 Thread() ： 分配新的 Thread 对象。 Thread(Runnable ta
SQLite3总共有三种事务类型：BEGIN [ DEFERRED /IMMEDIATE / EXCLUSIVE ] TRANSCATION，提供以下五种的文件锁状态，按锁的级别依次是：UNLOCKED / SHARED / RESERVERD / PENDING / EXCLUSIVE。
Collections 提供了多个synchronizedXxx()方法·，该方法可以将指定集合包装成线程同步的集合，从而解决多线程并发访问集合时的线程安全问题。
Semaphore 使用纯粹的内核时间(kernel-time)方式(等待时间很短)，并且支持在不同的进程间同步线程(像Mutex)。
Semaphore是J.U.C包下的许可控制类，维护了一个许可集，通常用于限制可以访问某些资源（物理或逻辑的）的线程数目，或对资源访问的许可控制。
使用FutureTask可以用泛型指定线程的返回值类型（Runnable的run方法没有返回值）
Vector 的思路和 ArrayList 基本是相同的，底层是数组保存元素，Vector 默认的容量是10，有一个增量系数，如果指定，那么每次都会增加一个系数的大小，否则就扩大一倍。
当正在运行的Java服务导致服务器的CPU突然飙高时，我们该如何排查定位到哪个接口的哪行代码导致CPU飙高的问题呢？我主要提供两个方案：
在接口开发时，有一种开发模式叫定时器模式，可以理解为每经过一段预设的时间就会执行一次事件，而在我们的工作中，这个事件所实现的功能一般是将两个系统的数据信息进行同步，这样就实现了两个系统通过接口进行对接的功能。
在Python3中，Python提供了一个内置模块 threading.Thread，可以很方便地让我们创建多线程。
Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。本文主要讲解的是： 线程控制（也称为调度 / 切换），即讲解功能性操作符中的：subscribeOn（） & observeOn（）
在 操作系统 中 , 进程 之间 的 内存空间 是 隔离的 , 不同的进程 拥有各自的 内存空间 ,
一个程序，当运算很充分（IO等操作很少）时，指定到单独一个CPU上运行会比不指定CPU运行时快。这中间主要有两个原因：
作用：通过ThreadDelay设定每个线程请求之前的等待时间（单位为毫秒）。
在测试环境进行压力测试时，我们可以把并发量设置的比较高，可以得出最大并发量。但是在生产环境下，有时候我们会根据客户的要求，可能只要求应用能满足用户使用就可以，且压测时要保证不系统正常、不崩溃。这时我们用到jmeter的限频。
导读：虽然已经有很多分析工具 jvisualvm,jstat,jmap,jstack,Memory Analyzer等。但可能不是大杂烩,或者线上无法分析等。所以看看arthas的功能，好用就用它了
一、为什么JavaScript是单线程？ JavaScript语言的一大特点就是单线程，也就是说，同一个时间只能做一件事。那么，为什么JavaScript不能有多个线程呢？这样能提高效率啊。 JavaScript的单线程，与它的用途有关。作为浏览器脚本语言，JavaScript的主要用途是与用户互动，以及操作DOM。这决定了它只能是单线程，否则会带来很复杂的同步问题。比如，假定JavaScript同时有两个线程，一个线程在某个DOM节点上添加内容，另一个线程删除了这个节点，这时浏览器应该以哪个线程为准？ 所
多线程在面试中经常会被问到，所以也是非常重要的知识。 看到一篇写的很不错的博客：http://www.cnblogs.com/GarfieldEr007/p/5746362.html 一、进程与线程概述 1.1、进程和线程定义 进程是具有一定独立功能的程序关于某个数据集合上的一次运行活动,进程是系统进行资源分配和调度的一个独立单位. 线程是进程的一个实体,是CPU调度和分派的基本单位,它是比进程更小的能独立运行的基本单位.线程自己基本上不拥有系统资源,只拥有一点在运
semaphore&cyclicbarrier&CountDownLatch的介绍
线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的堆栈大小，以默认的优先级运行，并处于多线程单元中。如果某个线程在托管代码中空闲（如正在等待某个事件）,则线程池将插入另一个辅助线程来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙，但队列中包含挂起的工作，则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队，但他们要等到其他线程完成后才启动。
该组件是作者偶然在翻阅公司一中间件源码的时候碰到的，觉得设计的非常精美、巧妙，花了点时间整理成文分享给大家。
在一个分布式系统中，由于涉及到多个实例同时对同一个资源加锁的问题，像传统的synchronized、ReentrantLock等单进程情况加锁的api就不再适用，需要使用分布式锁来保证多服务实例之间加锁的安全性。常见的分布式锁的实现方式有zookeeper和redis等。而由于redis分布式锁相对于比较简单，在实际的项目中，redis分布式锁被用于很多实际的业务场景中。
BlockingQueue是Java并发编程中的一个关键接口，位于java.util.concurrent包下。它提供了一种在多线程环境中安全地共享数据的机制，特别适用于生产者-消费者模型和任务调度等场景。在BlockingQueue中，生产者线程将数据放入队列，而消费者线程则从队列中取出数据，这样可以很好地实现线程之间的协调和通信。
项目中最近使用了多个定时任务处理业务需求，于是在实现业务逻辑过程中，产生了上图一些思考和疑问，现在利用空余时间进行一次复盘。
-------------------系统内建函数------------------- 1、字符串 str='这是一个字符串数据测试数据'对应 str[0]：获取str字符串中下标为0的字符。 str[3]：获取str字符串中下标为3的字符。 str[0:3]：获取到字符串中从下标为0到下标为3的字符串。
通过线程池性能稳定，也可以获取执行结果，并捕获异常。但是，在业务复杂情况下，一 个异步调用可能会依赖于另一个异步调用的执行结果。
很早前就看了RxJava，当时就觉得好牛掰，但是公司项目一直没有用起来，知识不用就会忘，前段时间突然要写RxJava，发现已经不会写了。所以今天再回头整理一下RxJava的头绪，一方面给其它想了解RxJava的人提供参考，另一方面也是给自己将来再遗忘时回来翻阅。
我们不妨设想，为了创建一个新的线程，我们需要做些什么？很显然，我们必须指明这个线程所要执行的代码，而这就是在Java中实现多线程我们所需要做的一切！
大家都知道，JavaScript是单线程的，也就是说，所有的任务只能在一个线程上完成，一次只能做一件事。前面的任务如果没有完成，后面就只能等着。所以，HTML5就提出了web Worker标准，表示JavaScript允许有多个线程，但是子线程完全受主线程的控制，并且子线程不能操作DOM，只有主线程可以操作DOM。所以 Web Worker 的最佳使用场景是执行一些开销较大的数据处理或计算任务，接下来我们就来具体的了解一下这个东西吧~
昨天的时候我们已经写过一版多线程的代码，很多同学对原理不是很清楚，那么我们今天先画个多线程执行时序图
本DEMO采用Executor框架来实现多线程的下载。 Executor原理：任务拆分为一些列的小任务，即Runnable，然后在提交给一个Executor执行，Executor.execute(Runnalbe) 。Executor在执行时使用内部的线程池完成操作。 本博文演示的从服务端多线程下载图片主要是通过HTTP请求头的Range，在线程池中初始化线程数，然后根据算法去计算，每个线程去下载指定Range范围的资源，每个线程现在完成后发送Message消息给主线程的handler ,当所有的线程都下载完成后,handler主动更新主线程UI。 详细代码请移步本人GITHUB
Java 中的定时器就类似于一个"闹钟",达到一个设定的时间之后,就会执行某个指定的好的代码。就像在学校有早八的课,会设置早上7:30的闹钟提醒自己去上课。所以的当我们使用定时器的时候,需要的设定一个时间和设置好一个对应的任务。Java标准库中提供了带有定时功能的类Timer。
RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences. 简单来说，rxJava 是一种 基于事件的，使用了可被观察序列 的异步 响应 扩展 的类库。
序列化机制是通过在运行时判断类的 serialVersionUID 来验证版本一致性的。在进行反序列化时，JVM会把传来的字节流中的 serialVersionUID 与本地相应实体类的 serialVersionUID 进行比较，如果相同就认为是一致的，可以进行反序列化，否则就会出现序列化版本不一致的异常 (InvalidCastException)。
但通常我们很少用这4个工厂方法去创建线程池，而是直接使用ThreadPoolExecutor类构造线程池，因为这些工厂方法最终也是调用这个类来创建线程池的。
在java中一个完整定时任务需要由Timer、TimerTask两个类来配合完成。 API中是这样定义他们的，Timer：一种工具，线程用其安排以后在后台线程中执行的任务。可安排任务执行一次，或者定期重复执行。由TimerTask：Timer 安排为一次执行或重复执行的任务。我们可以这样理解Timer是一种定时器工具，用来在一个后台线程计划执行指定任务，而TimerTask一个抽象类，它的子类代表一个可以被Timer计划的任务。
Java提供了一个操作Set、List和Map等集合的工具类：Collections，该工具类提供了大量的方法对集合元素进行排序、查询和修改等操作，还提供了将集合对象设置为不可变、对集合对象实现同步控制等方法。
一年前，我写了一篇《什么是 Event Loop？》，谈了我对Event Loop的理解。 上个月，我偶然看到了Philip Roberts的演讲《Help, I'm stuck in an event-loop》。这才尴尬地发现，自己的理解是错的。我决定重写这个题目，详细、完整、正确地描述JavaScript引擎的内部运行机制。下面就是我的重写。 进入正文之前，插播一条消息。我的新书《ECMAScript 6入门》出版了（版权页，内页1，内页2），铜版纸全彩印刷，非常精美，还附有索引（当然价格也比同类书籍
public Thread() :分配一个新的线程对象。 public Thread(String name) :分配一个指定名字的新的线程对象。 public Thread(Runnable target) :分配一个带有指定目标新的线程对象。 public Thread(Runnable target,String name) :分配一个带有指定目标新的线程对象并指定名字。 常用方法 public String getName() :获取当前线程名称。 public void start() :导致此线程开始执行; Java虚拟机调用此线程的run方法。 public void run() :此线程要执行的任务在此处定义代码。 public static void sleep(long millis) :使当前正在执行的线程以指定的毫秒数暂停（暂时停止执行）。 public static Thread currentThread() :返回对当前正在执行的线程对象的引用
作为 Java 程序员，无论是技术面试、项目研发或者是学习框架源码，不彻底掌握 Java 多线程的知识，做不到心中有数，干啥都没底气，尤其是技术深究时往往略显发憷。
计算机系统里每个进程（Process）都代表着一个运行着的程序，进程是对运行时程序的封装，系统进行资源调度和分配的基本单位。
__in HANDLE ExistingCompletionPort,
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
