一、生产者springcloud_eureka_provider (1)目录展示 (2)导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifac ...
分类:
编程语言 时间:
2019-12-17 18:54:19
阅读次数:
215
线程 1,生产者消费者模型 1. 什么是生产者与消费者模型 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题,生产者和消费者之间不直接通讯,而通过阻塞队列来通讯,阻塞队列就相当于一个缓冲区,平衡了生产者和消费者的处理能力 在并发编程中使用生产者和消费者模式能够解决大多数并发问题,该模式 ...
分类:
编程语言 时间:
2019-12-13 13:46:51
阅读次数:
89
课程回顾: 并行:在同一时间点上多个任务同时执行 并发:在同一时间段上多个任务同时执行 进程的三大基本状态: 就绪状态:所有进程需要的资源都获取到了,除了CPU 执行状态:获取到了所有资源包括CPU,进程处于运行状态 阻塞状态:程序停滞不在运行,放弃CPU,进程此时处于内存里 什么叫进程? 正在运行 ...
分类:
系统相关 时间:
2019-12-11 09:18:21
阅读次数:
107
生产者 package com.java.se.producer; import java.util.concurrent.BlockingQueue; public class Producer implements Runnable{ private BlockingQueue<Integer> ...
分类:
其他好文 时间:
2019-12-10 00:35:54
阅读次数:
108
进程,互斥锁,生产者消费者,线程 一、僵尸进程与孤儿进程 代码演示 二、子进程回收的两种方式 代码演示 三、进程守护 演示 四、进程间数据是隔离的 演示 五、进程互斥锁 演示 六、队列 演示 七、IPC(进程间通信) 演示 八、生产者与消费者 演示 子线程守护 十、线程互斥锁 演示 ...
分类:
编程语言 时间:
2019-12-07 23:13:24
阅读次数:
144
1 概述 目前我们部分系统还在使用Kafka0.8.2.2 的版本。 0.8.2.2版本发行于2014年10月28号,距今已经过去4年多的时间。 三年的时间,Kafka截至到(2018-02-28),已经累计发布了14个版本,最新版本为1.0.0,由此,0.8.2已经远远落后于Kafka的最新版本1 ...
分类:
其他好文 时间:
2019-12-07 14:12:04
阅读次数:
856
进程同步是对多个相关进程在执行次序上进行协调,使并发执行的多个进程之间按照一定的规则共享系统资源。 1、生产者消费者问题: 生产者、消费者问题生产者生产产品放入缓冲区中,消费者从缓冲区中取出产品去消费。不允许消费者从空缓冲区中取产品,也不允许生产者向已经满了的缓冲区添加产品。 2、过程描述: 生产者 ...
分类:
系统相关 时间:
2019-12-07 12:11:48
阅读次数:
405
在学习Celery之前,我先简单的去了解了一下什么是生产者消费者模式。 生产者消费者模式 在实际的软件开发过程中,经常会碰到如下场景:某个模块负责产生数据,这些数据由另一个模块来负责处理(此处的模块是广义的,可以是类、函数、线程、进程等)。产生数据的模块,就形象地称为生产者;而处理数据的模块,就称为 ...
分类:
其他好文 时间:
2019-12-02 18:43:48
阅读次数:
82
一.RabbitMQ的介绍 RabbitMQ是消息中间件的一种,消息中间件即分布式系统中完成消息的发送和接收的基础软件.这些软件有很多,包括ActiveMQ(apache公司的),RocketMQ(阿里巴巴公司的,现已经转让给apache). 消息中间件的工作过程可以用生产者消费者模型来表示.即,生 ...
分类:
编程语言 时间:
2019-12-01 20:37:14
阅读次数:
86
kafka 生产者、消费者与分区的关系 背景 最近和海康整数据对接, 需要将海康产生的结构化数据拿过来做二次识别. 基本的流程: 海康大数据 kafka server 平台 Kafka 的 topic 正常过车 topic: BAYONET_VEHICLEPASS 违法过车 topic: BAYON ...
分类:
其他好文 时间:
2019-11-29 18:25:16
阅读次数:
73