消息队列(Message Queue,简称MQ),从字面意思上看,本质是个队列,FIFO先入先出,只不过队列中存放的内容是message而已。 其主要用途:不同进程Process/线程Thread之间通信。 为什么会产生消息队列?有几个原因: 不同进程(process)之间传递消息时,两个进程之间耦 ...
分类:
其他好文 时间:
2020-04-17 20:05:56
阅读次数:
148
package thread.test; public class ThreadLocalDemo { /** * ThreadLocal变量,每个线程都有一个副本,互不干扰 */ private static final ThreadLocal<String> THREAD_LOCAL = new ...
分类:
编程语言 时间:
2020-04-17 00:11:52
阅读次数:
67
目的:运行Atlas并使用Azkaban执行操作任务 环境:Centos 6 内存大小:12G 启动下面的任务后还剩内存将近5G 问题: 当mysql_to_hdfs_db和其他job同时运行时集群很容易就会报错 Cannot create GC thread. Out of system reso ...
分类:
其他好文 时间:
2020-04-16 22:28:47
阅读次数:
86
使用CyclicBarrier模拟线程并发执行代码 package com.gaopeng.multithread; import java.util.concurrent.CountDownLatch; import java.util.concurrent.CyclicBarrier; impo ...
分类:
编程语言 时间:
2020-04-16 15:38:00
阅读次数:
63
给一个对象(obj)加锁,会在操作系统层面获取一个监视器(Monitor,有时候也叫管程)对象,对象obj的Markword会指向该Monitor对象,原本Markword中存放的分代年龄等信息会存放在Monitor对象里。Monitor里的Owner指向持有该对象obj的锁的线程Thread_1。 ...
分类:
其他好文 时间:
2020-04-16 14:57:58
阅读次数:
59
随着IOT领域智能穿戴、智能家居、智慧医疗等市场应用对蓝牙芯片低功耗、低成本要求的不断提高,PHY62系列芯片应运而生。 PHY6202是一款具有强大性能,高灵活性的超低功耗多协议蓝牙芯片,同时支持低功耗蓝牙,蓝牙5.0,蓝牙MESH,ZigBee,谷歌Thread,Mist等多种通信协议,是一款面 ...
分类:
其他好文 时间:
2020-04-16 14:51:34
阅读次数:
86
服务器端 1 from socket import * 2 from threading import Thread 3 sockets = [] 4 def main(): 5 #创建server_socket套接字对象 6 server_socket = socket(AF_INET,SOCK_ ...
分类:
编程语言 时间:
2020-04-16 10:28:16
阅读次数:
73
1.sleep()是Thread类的方法;而wait(),notify(),notifyAll()是Object类中定义的方法;2.Thread.sleep和Object.wait都会暂停当前的线程,Thread.sleep不会造成当前锁行为的变化,如果当前线程有锁,调用之后并不会释放锁;而Object.wait会释放当前对象锁.代码实现:packagetest111;importjava.uti
分类:
其他好文 时间:
2020-04-16 10:24:55
阅读次数:
76
java中线程是经常会提到的问题,但是实际开发工作却又很少用的技术(起码本人用的比较少)。下面介绍几种常见的线程实现方式 1、继承Thread类,重写run方法 我们通过集成Thread类并通过重写run方法的方式实现线程,然后通过start方法启动线程 public class MyThread ...
分类:
编程语言 时间:
2020-04-15 00:37:00
阅读次数:
69
一、异步任务 测试如下 1、不是异步方法的时候: 进行等待三秒再进行应答 @Service public class AsynService { public void hello(){ try { Thread.sleep(3000); } catch (InterruptedException ...
分类:
编程语言 时间:
2020-04-15 00:16:54
阅读次数:
72