文档章节

多线程之间通讯例子

 石头茨
发布于 2016/08/18 22:51
字数 234
阅读 6
收藏 0
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

import static com.hb.thread.lock.Business.*;

/**
 * 多线程之间的通讯
 */
public class ThreeConditionLock {
    public static void main(String[] arg) {
        Business bus = new Business();

        new Thread(new Runnable() {
            @Override
            public void run() {
                for (int i = 1; i < 4; i++) {
                    bus.sub1(i);
                }
            }
        }).start();

        new Thread(new Runnable() {
            @Override
            public void run() {
                for (int i = 1; i < 4; i++) {
                    bus.sub2(i);
                }
            }
        }).start();

        for (int i = 1; i < 4; i++) {
            bus.sub3(i);
        }
    }
}

class Business {
    private Lock lock = new ReentrantLock();
    private Condition condition1 = lock.newCondition();
    private Condition condition2 = lock.newCondition();
    private Condition condition3 = lock.newCondition();

    private int count = 1;

    public void sub1(int i) {
        lock.lock();
        try {
            while (count != 1) {
                try {
                    condition1.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

            for (int j = 1; j < 5; j++) {
                System.out.println("No.1 Thread ,当前序列 : " + j + "第" + i + "循环");
            }
            count++;
            condition2.signal();
        } finally {
            lock.unlock();
        }
    }

    public void sub2(int i) {
        lock.lock();
        try {
            while (count != 2) {
                try {
                    condition2.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

            for (int j = 1; j < 5; j++) {
                System.out.println("No.2 Thread ,当前序列 : " + j + "第" + i + "循环");
            }
            count++;
            condition3.signal();
        } finally {
            lock.unlock();
        }
    }

    public void sub3(int i) {
        lock.lock();
        try {
            while (count != 3) {
                try {
                    condition3.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

            for (int j = 1; j < 5; j++) {
                System.out.println("No.3 Thread ,当前序列 : " + j + "第" + i + "循环");
            }
            count = 1;
            condition1.signal();
        } finally {
            lock.unlock();
        }
    }
}

© 著作权归作者所有

上一篇: XML工具类封装
粉丝 17
博文 6
码字总数 2277
作品 0
武汉
私信 提问
JAVA多线程之四---同一线程化

同线程也是一种并发模型,指的是从单线程系统扩展中出N个单线程系统。 N个单线程在系统中并行运行。同线程不等于单线程,因为,它里面也包含着多个线程。 只是每个线程都像单线程那样运行。 ...

闲等莫
2018/03/16
22
0
block语法

一、block应用范围 1、动画的转场 2、网络的事件处理 3、两个对象或者多个对象之间的通讯 4、多线程的处理 (从iOS4.0开始就应用得非常广泛) 二、Block block和C语言中的函数(函数指针)有...

Cy_Star
2017/11/22
0
0
一篇文章理清Python多线程之同步条件,信号量和队列

公众号:pythonislover 今天这篇文章大概介绍下python多线程中的同步条件Event,信号量(Semaphore)和队列(queue),这是我们多线程系列的最后一篇文章,以后将会进入python多进程的系列。 同步...

南山yrg
04/30
0
0
Swift多线程之Operation:按优先级加载图片

乖乖的,俺又来了。上一个系列写传感器,特别庆幸自己在开篇的时候就立下了一个Flag,不然那个系列估计到现在就不知道被自己偏到什么地方去了。众所周知的iOS有好多传感器,配合各种传感器可...

非典型技术宅
2018/10/29
0
0
组件式 RPC 框架--grain

grain 是一个极简的、组件式的 RPC 框架,灵活且适合渐进学习,可与任何框架整合。同时包含(系统通用多线程模型与消息通讯、多对多关系的分布式锁、基于 Servlet 的 HTTP 框架、基于系统通用...

电霸儿
2017/11/17
436
1

没有更多内容

加载失败,请刷新页面

加载更多

3_数组

3_数组

行者终成事
18分钟前
2
0
经典系统设计面试题解析:如何设计TinyURL(二)

原文链接:https://www.educative.io/courses/grokking-the-system-design-interview/m2ygV4E81AR 编者注:本文以一道经典的系统设计面试题:《如何设计TinyURL》的参考答案和解析为例,帮助...

APEMESH
今天
7
0
使用logstash同步MySQL数据到ES

概述   在生成业务常有将MySQL数据同步到ES的需求,如果需要很高的定制化,往往需要开发同步程序用于处理数据。但没有特殊业务需求,官方提供的logstash就很有优势了。   在使用logstas...

zxiaofan666
今天
10
0
X-MSG-IM-分布式信令跟踪能力

经过一周多的鏖战, X-MSG-IM的分布式信令跟踪能力已基本具备, 特点是: 实时. 只有要RX/TX就会实时产生信令跟踪事件, 先入kafka, 再入influxdb待查. 同时提供实时sub/pub接口. 完备. 可以完整...

dev5
今天
7
0
OpenJDK之CyclicBarrier

OpenJDK8,本人看的是openJDK。以前就看过,只是经常忘记,所以记录下 图1 CyclicBarrier是Doug Lea在JDK1.5中引入的,作用就不详细描述了,主要有如下俩个方法使用: await()方法,如果当前线...

克虏伯
今天
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部