Java编程线程间通信与信号量代码示例

 更新时间:2017年12月06日 09:12:47   作者:Sides  
这篇文章主要介绍了Java编程线程间通信与信号量代码示例,具有一定借鉴价值,需要的朋友可以参考下。

1.信号量Semaphore

先说说Semaphore,Semaphore可以控制某个资源可被同时访问的个数,通过acquire()获取一个许可,如果没有就等待,而release()释放一个许可。一般用于控制并发线程数,及线程间互斥。另外重入锁ReentrantLock也可以实现该功能,但实现上要复杂些。

功能就类似厕所有5个坑,假如有10个人要上厕所,那么同时只能有多少个人去上厕所呢?同时只能有5个人能够占用,当5个人中的任何一个人让开后,其中等待的另外5个人中又有一个人可以占用了。另外等待的5个人中可以是随机获得优先机会,也可以是按照先来后到的顺序获得机会。

单个信号量的Semaphore对象可以实现互斥锁的功能,并且可以是由一个线程获得了“锁”,再由另一个线程释放“锁”,这可应用于死锁恢复的一些场合。

例子:

/**
 * @Description:
 * @param @param args
 * @return void 返回类型
 */
public static void main(String[] args) {
  // 线程池
  ExecutorService exec = Executors.newCachedThreadPool();
  // 只能5个线程同时访问
  final Semaphore semp = new Semaphore(5);
  // 模拟20个客户端访问
  for (int index = 0; index < 20; index++) {
    final int NO = index;
    Runnable run = new Runnable() {
      public void run() {
        try {
          // 获取许可
          semp.acquire();
          System.out.println("获得Accessing: " + NO);
          Thread.sleep((long) (Math.random() * 10000));
          // 访问完后,释放
          semp.release();
          System.out.println("剩余可用信号-----------------"
              + semp.availablePermits());
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    };
    exec.execute(run);
  }
  // 退出线程池
  exec.shutdown();
}

输出结果(可以想想为什么会这样输出):

获得Accessing: 1
获得Accessing: 5
获得Accessing: 2
获得Accessing: 3
获得Accessing: 0
剩余可用信号-----------------1
获得Accessing: 4
剩余可用信号-----------------1
获得Accessing: 9
剩余可用信号-----------------1
获得Accessing: 8
剩余可用信号-----------------1
获得Accessing: 6
剩余可用信号-----------------1
获得Accessing: 10
剩余可用信号-----------------1
获得Accessing: 11
剩余可用信号-----------------1
获得Accessing: 12
剩余可用信号-----------------1
获得Accessing: 13
剩余可用信号-----------------1
获得Accessing: 7
剩余可用信号-----------------1
获得Accessing: 15
剩余可用信号-----------------1
获得Accessing: 16
剩余可用信号-----------------1
获得Accessing: 17
剩余可用信号-----------------1
获得Accessing: 14
剩余可用信号-----------------1
获得Accessing: 18
剩余可用信号-----------------1
获得Accessing: 19
剩余可用信号-----------------1
剩余可用信号-----------------2
剩余可用信号-----------------3
剩余可用信号-----------------4
剩余可用信号-----------------5

2.使用PIPE作为线程间通信桥梁

Pipe有一个source通道和一个sink通道。数据会被写到sink通道,从source通道读取。一进一出。先作为初步了解怎么使用。

值得注意的是该类在java.nio.channels下,说明该类属于nio方式的数据通信方式,那就使用Buffer来缓冲数据。

Pipe原理的图示:

Pipe就是个空管子,这个空管子一头可以从管子里往外读,一头可以往管子里写

操作流程:

1.首先要有一个对象往这个空管子里面写。写到哪里呢?这个空管子是有一点空间的,就在这个管子里。

写的时候就是写到管子本身包含的这段空间里的。这段空间大小是1024个字节。

2.然后另一个对象才能将这个装满了的管子里的内容读出来。

上代码

package com.jx.test;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;
public class testPipe {
	/**
   * @Description:
   * @param @param args
   * @return void 返回类型
   * @throws IOException
   */
	public static void main(String[] args) throws IOException {
		// 创建一个管道
		Pipe pipe = Pipe.open();
		final Pipe.SinkChannel psic = pipe.sink();
		// 要向管道写数据,需要访问sink通道
		final Pipe.SourceChannel psoc = pipe.source();
		// 从读取管道的数据,需要访问source通道
		Thread tPwriter = new Thread() {
			public void run() {
				try {
					System.out.println("send.....");
					// 创建一个线程,利用管道的写入口Pipe.SinkChannel类型的psic往管道里写入指定ByteBuffer的内容
					int res = psic.write(ByteBuffer
										              .wrap("Hello,Pipe!测试通讯.....".getBytes("utf-16BE")));
					System.out.println("send size:" + res);
				}
				catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
		;
		Thread tPreader = new Thread() {
			public void run() {
				int bbufferSize = 1024 * 2;
				ByteBuffer bbuffer = ByteBuffer.allocate(bbufferSize);
				try {
					System.out.println("recive.....");
					// 创建一个线程,利用管道的读入口Pipe.SourceChannel类型的psoc将管道里内容读到指定的ByteBuffer中          
					int res = psoc.read(bbuffer);
					//数据未
					System.out.println("recive size:"+res+" Content:" + ByteBufferToString(bbuffer));
				}
				catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
		;
		tPwriter.start();
		tPreader.start();
	}
	/**
   *ByteBuffer--> String的转换函数
   */
	public static String ByteBufferToString(ByteBuffer content) {
		if (content == null || content.limit() <= 0
				        || (content.limit() == content.remaining())) {
			System.out.println("不存在或内容为空!");
			return null;
		}
		int contentSize = content.limit() - content.remaining();
		StringBuffer resultStr = new StringBuffer();
		for (int i = 0; i < contentSize; i += 2) {
			resultStr.append(content.getchar(i));
		}
		return resultStr.toString();
	}
}

总结

以上就是本文关于Java编程线程间通信与信号量代码示例的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!

相关文章

  • Springboot引入hibernate配置自动建表并进行增删改查操作

    Springboot引入hibernate配置自动建表并进行增删改查操作

    这篇文章主要介绍了Springboot引入hibernate配置自动建表并进行增删改查,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-09-09
  • SpringBoot在IDEA中实现热部署(JRebel实用版)

    SpringBoot在IDEA中实现热部署(JRebel实用版)

    这篇文章主要介绍了SpringBoot在IDEA中实现热部署(JRebel实用版),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-05-05
  • maven插件maven-assembly-plugin打包归纳文件zip/tar使用

    maven插件maven-assembly-plugin打包归纳文件zip/tar使用

    java项目运行的文件需要jar或者war格式,同时还需要使用Java命令,本文主要介绍了maven插件maven-assembly-plugin打包归纳文件zip/tar使用,具有一定的参考价值,感兴趣的可以了解一下
    2024-02-02
  • 枚举java语言中的修饰符组合的实例代码

    枚举java语言中的修饰符组合的实例代码

    这篇文章主要介绍了枚举java语言中的修饰符组合,本文通过实例代码给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-07-07
  • 2024版本IDEA创建Servlet模板的图文教程

    2024版本IDEA创建Servlet模板的图文教程

    新版IDEA 2024.1.4中,用户需要自行创建Servlet模板以解决Web项目无法通过右键创建Servlet的问题,本文详细介绍了添加ServletAnnotatedClass.java模板的步骤,帮助用户快速配置并使用新的Servlet模板,需要的朋友可以参考下
    2024-10-10
  • Spring Boot学习入门之统一异常处理详解

    Spring Boot学习入门之统一异常处理详解

    我们在做Web应用的时候,请求处理过程中发生错误是非常常见的情况。下面这篇文章主要给大家介绍了关于Spring Boot学习入门之统一异常处理的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下。
    2017-09-09
  • lombok 子类中如何使用@Builder问题

    lombok 子类中如何使用@Builder问题

    这篇文章主要介绍了lombok 子类中如何使用@Builder问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-09-09
  • 关于spring依赖注入的方式以及优缺点

    关于spring依赖注入的方式以及优缺点

    这篇文章主要介绍了关于spring依赖注入的方式以及优缺点,依赖注入,是IOC的一个方面,是个通常的概念,它有多种解释,这概念是说你不用创建对象,而只需要描述它如何被创建,需要的朋友可以参考下
    2023-07-07
  • 关于idea无法修改模板中jdk版本问题

    关于idea无法修改模板中jdk版本问题

    这篇文章主要介绍了关于idea无法修改模板中jdk版本问题,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-10-10
  • SpringBoot 替换 if 的参数校验示例代码

    SpringBoot 替换 if 的参数校验示例代码

    Spring Validation是对hibernate validation的二次封装,用于支持spring mvc参数自动校验,接下来,我们以spring-boot项目为例,介绍Spring Validation的使用,需要的朋友可以参考下
    2022-12-12

最新评论