springBoot接口排队(串行执行)

在调用接口时将线程号(多实例的情况下得用uuid，线程号可能会重复)存入redis队列，查询队首线程号(uuid)如果是当前线程，则执行逻辑、出队，否则等待。

后调用的接口后执行了，如果不加该注解的情况如下，执行快的先执行完：

假如不考虑多租户和多实例的情况，就有很多种实现方式

输出如下

实现如下：

输出如下：

实现方式和使用ConcurrentLinkedQueue方式一样，BlockingQueue关键在于 take 方法，当队列为空时，take会阻塞，适合实现生产者消费者模式。

看一下take的源码，当队列为空，调用的是await，当队列不为空时，出队，再判断队列还不为空，唤醒其他take的线程

再看一下offer的源码，当队列不为空，唤醒take的线程

一般步骤

1 file core文件，可以显示出core文件是哪个进程产生的

2使用gdb或者dbx加载core文件， gdb 进程名 core文件

3where,显示堆栈信息，显示出coredump的地方

例如有个程序叫 ABC，产生了一个叫core的core文件，

那么输入 file core, 会显示 这个core文件是由ABC产生的，

然后输入 gdb ABC core装截core文件，

然后 输入 where 显示堆栈信息

在单线程程序中，我们经常要使用 全局变量 来实现多个函数间共享数据。在多线程环境下，由于数据空间是共享的，因此全局变量也为所有线程所共有。但有时在应用程序设计中有必要提供 线程私有 的全局变量，仅在某个线程中有效，但可以跨多个函数访问，这样每个线程访问它自己独立的数据空间，而不用担心和其它线程的同步访问。

这样在一个线程内部的各个函数都能访问、但其它线程不能访问的变量，我们就需要使用 线程局部静态变量 (Static memory local to a thread) 同时也可称之为 线程特有数据 （Thread-Specific Data 或 TSD），或者 线程局部存储 （Thread-Local Storage 或 TLS）。

POSIX 线程库提供了如下 API 来管理线程特有数据（TSD）：

第一参数 key 指向 pthread_key_t 的对象的指针。请 注意 这里 pthread_key_t 的对象占用的空间是用户事先分配好的， pthread_key_create 不会动态生成 pthread_key_t 对象。

第二参数 desctructor ，如果这个参数不为空，那么当每个线程结束时，系统将调用这个函数来释放绑定在这个键上的内存块。

有时我们在线程里初始化时，需要避免重复初始化。我们希望一个线程里只调用 pthread_key_create 一次，这时就要使用 pthread_once 与它配合。

第一个参数 once_control 指向一个 pthread_once_t 对象，这个对象必须是常量 PTHREAD_ONCE_INIT ，否则 pthread_once 函数会出现不可预料的结果。

第二个参数 init_routine ，是调用的初始化函数，不能有参数，不能有返回值。

如果成功则返回0，失败返回非0值。

创建完键后，必须将其与线程数据关联起来。关联后也可以获得某一键对应的线程数据。关联键和数据使用的函数为：

第一参数 key 指向键。

第二参数 value 是欲关联的数据。

函数成功则返回0，失败返回非0值。

注意： 用 pthread_setspecific 为一个键指定新的线程数据时，并不会主动调用析构函数释放之前的内存，所以调用线程必须自己释放原有的线程数据以回收内存。

获取与某一个键关联的数据使用函数的函数为：

参数 key 指向键。

如果有与此键对应的数据，则函数返回该数据，否则返回NULL。

删除一个键使用的函数为：

参数 key 为要删除的键。

成功则返回0，失败返回非0值。

注意： 该函数将键设置为可用，以供下一次调用 pthread_key_create() 使用。它并不检查当前是否有线程正在使用该键对应的线程数据，所以它并不会触发函数 pthread_key_create 中定义的 destructor 函数，也就不会释放该键关联的线程数据所占用的内存资源，而且在将 key 设置为可用后，在线程退出时也不会再调用析构函数。所以在将 key 设置为可用之前，必须要确定:

在 Linux 中每个进程有一个全局的数组 __pthread_keys ，数组中存放着 称为 key 的结构体，定义类似如下：

在 key 结构中 seq 为一个序列号，用来作为使用标志指示这个结构在数组中是否正在使用，初始化时被设为0，即表示 不在使用 。 destructor 用来存放一个析构函数指针。

pthread_create_key 会从数组中找到一个还未使用的 key 元素，将其序列号 seq 加1，并记录析构函数地址，并将 key 在数组 __pthread_keys 中的 下标 作为返回值返回。那么如何判断一个 key 正在使用呢？

如果 key 的序列号 seq 为偶数则表示未分配，分配时将 seq 加1变成奇数，即表示正在使用。这个 *** 作过程采用原子 CAS 来完成，以保证线程安全。在 pthread_key_delete() 时也将序列号 seq 加1，表示可以再被使用，通过序列号机制来保证回收的 key 不会被复用（复用 key 可能会导致线程在退出时可能会调用错误的析构函数）。但是一直加1会导致序列号回绕，还是会复用 key ，所以调用 pthread_create_key 获取可用的 key 时会检查是否有回绕风险，如果有则创建失败。

除了进程范围内的 key 结构数组外，系统还在进程中维护关于每个线程的控制块 TCB（用于管理寄存器，线程栈等），里面有一个 pthread_key_data 类型的数组。这个数组中的元素数量和进程中的 key 数组数量相等。 pthread_key_data 的定义类似如下：

根据 pthread_key_create() 返回的可用的 key 在 __pthread_keys 数组中的下标， pthread_setspecific() 在 pthread_key_data 的数组 中定位相同下标的一个元素 pthread_key_data ，并设置其序号 seq 设置为对应的 key 的序列号，数据指针 data 指向设置线程特有数据（TSD）的值。

pthread_getspecific() 用于将 pthread_setspecific() 设置的 data 取出。

线程退出时， pthread_key_data 中的序号 seq 用于判断该 key 是否仍在使用中（即与在 __pthread_keys 中的同一个下标对应的 key 的序列号 seq 是否相同），若是则将 pthread_key_data 中 data（即 线程特有数据 TSD）作为参数调用析构函数。

由于系统在每个进程中 pthread_key_t 类型的数量是有限的，所有在进程中并不能获取无限个 pthread_key_t 类型。Linux 中可以通过 PTHREAD_KEY_MAX（定义于 limitsh 文件中）或者系统调用 sysconf(_SC_THREAD_KEYS_MAX) 来确定当前系统最多支持多少个 key 。 Linux 中默认是 1024 个 key，这对大多数程序来书已经够了。如果一个线程中有多个线程局部存储变量（TLS），通常可以将这些变量封装到一个数据结构中，然后使用封装后的数据结构和一个线程局部变量相关联，这样就能减少对键值的使用。

>

方法一：可以通过/proc/线程ID/stack来获取指定线程当前的调用栈，但是该方案存在限制：可能不能准确获取出问题的时候该线程的调用栈

方法二：通过内核接口save_stack_trace_tsk和%pS，在程序检测到异常的时候打印出对应的调用栈用于问题定位，具体的方法(从内核/proc文件系统处理打印调用栈的proc_pid_stack中简单修改而来)：

[cpp] view plain copy

static int kprink_stack(struct task_struct task)

{

struct stack_trace trace;

unsigned long entries;

int err;

entries = kmalloc(MAX_STACK_TRACE_DEPTH sizeof(entries), GFP_KERNEL);

if (!entries)

return -ENOMEM;

tracenr_entries = 0;/调用返回后，为记录的调用栈中的有效符号的个数/

tracemax_entries = MAX_STACK_TRACE_DEPTH;/传入的traceentries的大小，save_stack_trace_tsk最多保持该数量的调用栈符号/

traceentries = entries;/返回的符号地址保存在这里/

traceskip = 0;/从调用栈的顶开始，忽略的调用栈符号数量/

err = lock_trace(task);

if (!err) {

save_stack_trace_tsk(task, &trace);

for (i = 0; i < tracenr_entries; i++) {

printk(m, "[<%pK>] %pS\n",

(void )entries[i], (void )entries[i]);

}

unlock_trace(task);

}

kfree(entries);

return err;

}

说明：其中的%pS用于打印内核符号，内核的相关处理见printk--->vprintk--->vscnprintf-->vsnprintf-->symbol_string的处理

title: 如何找到占用CPU和内存最高的线程

date: 2017-03-01

tags: Java

一、如何找到CPU和内存占用最高的线程

代码示例

我们先来写一段代码

@Test

public void testLinuxTop() throws Exception{

boolean b=true;

Systemoutprintln("start the cpu Thread");

while (b){

int i=(int)Mathrandom()1000;

if (i%3==1){

}

if (i==1000){

Systemoutprintln("stop");

b=false;

}

}

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

随便写了个死循环，然后怎么看下CPU占用情况呢？

TOP命令

先用ps -ef|grep tomcat查看一下你当前tomcat的进程号，比如我看出来我的进程号是8545

然后用TOP命令查看当前所有进程

top -p 8545

top -p 8545 -H //这样也可以

1

2

1

2

使用地址中，进入了下面这个界面之后就要按H了

于是你就会看到下面这张

这里写描述

CPU占用接近满了，内存占用30M，怎么会占用这么多？OK，我们记住PID 8545

jstack命令

OK，我们在栈里面来找出这段代码，可以直接用jstack把栈里面的东西打出来

直接使用下面的就可以

jstack 8545 > stacklog 在你的当前目录下面就会出现一个stacklog文件，这是包括所有的栈信息的，这里的8545是tomcat的进程号、tomcat的进程号、tomcat的进程号，重要的事情强调一下

如何找到有问题的代码呢？

我们刚才拿到了一个CPU最高的进程号8545，OK，转化为16进制，使用下面命令

printf "%x\n" 8545

//或者

printf 0x%x 8545

1

2

3

1

2

3

上面两种都可以拿到16进制的8545，或者你自己去用计算器拿去，这里我们得到的是0x2162或者2161（上面一种可以直接拿到2161，没有0x），我们要的就是2161

可以直接到jstacklog文件里面去搜索，就看到出问题的代码了

想直接看

下面提供一种直接看的方法

jstack 8545|grep -A 30 2162

1

1

得到线程堆栈信息中2162这个线程所在行的后面30行

question

41 我使用jstack pid报错了怎么办？

使用jstack pid可能会出现8545 operation permitted之类的错误，解决办法，请切换至root用户执行命令

over

命令很简单:

~0s 切换到0号线程

~3s 切换到3号线程

一些其他命令:

~e !clrstack 遍历每个线程, 依次输出它们的托管调用栈

!threads 查看所有的托管线程

一般种子可以以当前的系统时间，这是完全随机的

算法1：平方取中法。

1）将种子设为X0，并mod 10000得到4位数

2）将它平方得到一个8位数（不足8位时前面补0）

3）取中间的4位数可得到下一个4位随机数X1

4）重复1-3步，即可产生多个随机数

这个算法的一个主要缺点是最终它会退化成0，不能继续产生随机数。

算法2：线性同余法

1）将种子设为X0，

2）用一个算法X(n+1）=(aX(n)+b) mod c产生X(n+1）

一般将c取得很大，可产生0到c-1之间的伪随机数

该算法的一个缺点是会出现循环。

在windows平台下，可以考虑将如下参数作为影响种子的因素。

⒈GetTickCount()

系统启动以来的嘀嗒时间

说明：该时间与系统运行时长相关，

⒉GetCurrentProcessId()

当前进程Id号

说明：该Id与系统启动进程数量及次序有关，一般波动范围较小。

⒊GetCurrentProcess()

当前进程句柄

说明：该句柄实质就是内存地址，但每次进程启动时地址值是不确定的。

⒋GetProcessTimes()

进程时间参数

说明：-

⒌GetCurrentThreadId()

当前线程Id号

⒍GetCurrentThread()

当前线程句柄

⒎GetThreadTimes()

线程时间参数

⒏GetCurrentHwProfile()

Profile配置文件

⒐GetSysColor()

系统Color

⒑GetSystemInfo()

系统信息

⒒GetSystemPowerStatus()

电源状态

⒓GetKeyboardState()

键盘状态

⒔GlobalMemoryStatus()

内存状态

⒕time()

当前时间 秒

⒖GUID

各硬件设备GUID

⒗MAC

网卡mac

⒘CPUID

CPU Id号

⒙声卡录音噪音

该参量与环境相关

⒚用户键盘间隔时间

该参量与用户习惯相关

其次，尽最大可能增加这些因素的维度。这里说的维度是指

种子结果与因素之间的关联程度。一般使用hash函数对多个

因素进行哈希运算。这样得到的种子具有较强的散列特性。

通过以上技术手段得到的种子产生的伪随机数是具有较好

统计特性的，它不依赖于某一台机器，某一时刻，某一方法，

而是复杂多变、让人捉摸不透难于重现的。

以上就是关于springBoot接口排队(串行执行)全部的内容，包括:springBoot接口排队(串行执行)、gdb如何查看core文件中各个线程的信号、线程特有数据(Thread Specific Data)等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！