需求背景 利用线程来模拟生产者和消费者模型 系统建模 这个系统涉及到三个角色，生产者，消费者，任务队列，三个角色之间的关系非常简单，生产者和消费者拥有一个任务队列的引用，生产者负责往队列中放置对象(id),消费者负责从队列中获取对象(id),其关联关系如下 方案1 因为是多线程操作，所以对任务的存取 ...
分类：
编程语言 时间：
2017-09-18 13:28:57
阅读次数：
278
1.启动不起来 查看JobManager日志： 解决方案：/etc/hosts中配置的主机名都是小写，但是在Flink配置文件（flink-config.yaml、masters、slaves）中配置的都是大写的hostname，将flink配置文件中的hostname都改为小写或者IP地址 2.运 ...
分类：
其他好文 时间：
2017-09-16 23:23:02
阅读次数：
1825
一：概念 线程通信中经常用到wait和notify，顾名思义，wait即让当前线程处于等待状态，notify通知锁对象 上的另一个线程被唤醒，这里的唤醒是指可以去争夺锁资源，nofityAll是唤醒该对象上面所有处于 wait状态的线程 二：示例 线程t2一运行就处于wait等待状态，然后线程t1运 ...
分类：
其他好文 时间：
2017-09-16 20:23:38
阅读次数：
213
Treead中使用wair() 和notify() ps:我也是一个新手，有问题欢迎交流，780720038@qq.com 我直接贴代码了 ，ceshi2.java 1 2 public class ceshi2 { 3 4 public static void main(String[] args ...
分类：
编程语言 时间：
2017-09-14 16:43:26
阅读次数：
222
1 目录 2 线程概述 3 线程的定义 4 线程的启动 5 线程的状态 6 线程的方法属性 1.线程概述 线程是一个程序的多个执行路径，执行调度的单元，依托于进程的存在。线不仅可以共享进程的内在，而且还拥有一个属于自己的内存空间，这段内存空间就是线程栈，是在建立线程时系统分配的，主要用来保存线内部所 ...
分类：
其他好文 时间：
2017-09-14 12:01:47
阅读次数：
135
为了解决对共享存储区的访问冲突，Java 引入了同步机制。但显然不够，因为在任意时刻所要求的资源不一定已经准备好了被访问，反过来，同一时刻准备好了的资源也可能不止一个。 为解决访问控制问题，Java 引入阻塞机制。阻塞指的是暂停一个Java线程同步的执行以等待某个条件发生（如某资源就绪）。 slee ...
分类：
编程语言 时间：
2017-09-13 15:20:41
阅读次数：
234
一、任务 创建20个线程，其中10个线程是将数据备份到 A 数据库中，另外10 个线程将数据备份到 B 数据库中，并且备份 A 数据库和 备份 B 数据库的是交叉运行的。 二、实现 1、实现备份 A 数据库和备份 B 数据库的 task。 2、分别创建线程执行 备份任务 3、执行任务查看结果 三、结 ...
分类：
编程语言 时间：
2017-09-12 13:45:40
阅读次数：
165
使用wait，notify时，一定要先获取该对象的锁，才可以调用。即：外面要使用synchronized包含。注意只有相同的对象，调用notify方法，才可以唤醒调用wait进入唤醒的方法。 ...
分类：
编程语言 时间：
2017-09-10 23:44:13
阅读次数：
266
Java线程的同步(七中方法)：同步方法同步代码块wait和notify方法使用特殊域变量（volatile）使用重入锁使用ThreadLocal使用阻塞队列BlockingQueue使用原子变量实现线程同步AtomicInteger
分类：
编程语言 时间：
2017-09-09 23:18:44
阅读次数：
193
// 声明一个委托. delegate void Del(string str); // 声明一个与委托签名相同的方法. static void Notify(string name) { Console.WriteLine("Notification received for: {0}", nam... ...
