java实现golang类似的chan
版权声明：本文为博主原创文章，未经博主允许不得转载。 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操作，写完这段代码有种打通了任督二脉的感觉，语言不再是障碍
正文到此结束
热门推荐
相关文章
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
