内容简介：版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/lastsweetop/article/details/83992037
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/lastsweetop/article/details/83992037
java版本的CSP操作
public class Chan<T> {
private T message;
private boolean empty = true;
public synchronized T take() {
while (empty) {
try {
wait();
} catch (InterruptedException e) {
}
}
empty = true;
notifyAll();
return message;
}
public synchronized void put(T message) {
while (!empty) {
try {
wait();
} catch (InterruptedException e) {
}
}
empty = false;
this.message = message;
notifyAll();
}
}
基本的csp操作上面就可以了，但是如果想实现golang的select模型，就要对消息进行改造一下：
class ChanMessage<T> {
private String type;
private T data;
public ChanMessage(String type, T data) {
this.type = type;
this.data = data;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
}
public class Chan<T extends ChanMessage> {
private T message;
private boolean empty = true;
public synchronized T take() {
while (empty) {
try {
wait();
} catch (InterruptedException e) {
}
}
empty = true;
notifyAll();
return message;
}
public synchronized void put(T message) {
while (!empty) {
try {
wait();
} catch (InterruptedException e) {
}
}
empty = false;
this.message = message;
notifyAll();
}
public static void main(String[] args) {
Chan<ChanMessage<Integer>> chanMessageChan = new Chan<>();
new Thread(() -> {
chanMessageChan.put(new ChanMessage<>("timeout", new Integer(1)));
}).start();
new Thread(() -> {
ChanMessage<Integer> chanMessage = chanMessageChan.take();
switch (chanMessage.getType()) {
case "timeout":
System.out.println(chanMessage.getData());
break;
default:
break;
}
}).start();
}
}
至此就用 java 实现了golang的select操作，写完这段代码有种打通了任督二脉的感觉，语言不再是障碍
以上所述就是小编给大家介绍的《java实现golang类似的chan》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
Java并发编程实战
Brian Goetz、Tim Peierls、Joshua Bloch、Joseph Bowbeer、David Holmes、Doug Lea / 童云兰 / 机械工业出版社华章公司 / 2012-2 / 69.00元
本书深入浅出地介绍了Java线程和并发，是一本完美的Java并发参考手册。书中从并发性和线程安全性的基本概念出发，介绍了如何使用类库提供的基本并发构建块，用于避免并发危险、构造线程安全的类及验证线程安全的规则，如何将小的线程安全类组合成更大的线程安全类，如何利用线程来提高并发应用程序的吞吐量，如何识别可并行执行的任务，如何提高单线程子系统的响应性，如何确保并发程序执行预期任务，如何提高并发代码的性......一起来看看 《Java并发编程实战》 这本书的介绍吧!
