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

/** * @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

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();	}}