3以上两种方式的接合，将共享数据封装在另外一个对象中，每个线程
对共享数据的操作方法也分配到那个对象身上，对象作为这个外部类中的成员变量
或方法中的局部变量，每个线程的runnable对象作为外部类中的成员内部类或局部内部类
总之，要同步互斥的几段代码最好分别放在独立的方法中，这些方法再
放在同一个类中，这样比较容易实现它们之间的互斥和通信
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* 2把这些runnable对象作为某一类中的内部类，共享数据作为这个 外部类中的成员变量，每个线程对共享数据的操作方法也分配给
* 外部类，以便实现对共享数据进行的各个操作的互斥和通信，作为内部类 的各个runnable对象调用外部类的这些方法 jdk1.5+中的线程通信
*
* @author liyutao
*
*/
public class Test5 {
// private static ShareData1 data1 = new ShareData1();//共享数据
public static void main(String[] args) {
final ShareD data1 = new ShareD();// 共享数据
// 为了实现效果 让两个匿名内部类线程之间可以进行通信
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();
boolean bShouldSub = true;
// {
lock.lock();
try {
while (!bShouldSub) {
try {
condition.await();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// runnable对象作为某一类中的内部类
new Thread(new Runnable() {
@Override
public void run() {
data1.increment();
}
}).start();
bShouldSub = true;
condition.signal();
} finally {
lock.unlock();
}
// }
// {
lock.lock();
try {
while (!bShouldSub) {
try {
condition.await();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// runnable对象作为某一类中的内部类
new Thread(new Runnable() {
@Override
public void run() {
data1.decrement();
}
}).start();
bShouldSub = false;
condition.signal();
} finally {
lock.unlock();
}
}
// }
}
class ShareD {
private int j = 0;
public void increment() {
while (j < 10) {
j++;
System.out.println("increment=" + j);
}
}
public void decrement() {
while (j > 0) {
j--;
System.out.println("decrement=" + j);
}
}
}
/**
* 1把共享数据封装在另外一个对象中，然后将这个对象逐一传递
给各个runnable对象，每个线程对共享数据的操作方法也分配
到那个对象本身上，这样容易实现针对该数据进行的各个操作
的互斥和通信
*代码中用到了传统的线程间通信
* @author liyutao
*/
public class Test {
public static void main(String[] args) {
ShareData1 data2 = new ShareData1();
new Thread(new MyRunnable1(data2)).start();
new Thread(new MyRunnable2(data2)).start();
}
}
class MyRunnable1 implements Runnable{
private ShareData1 data1;
public MyRunnable1(ShareData1 data1){
this.data1 = data1;
}
public void run() {
data1.decrement();
}
}
class MyRunnable2 implements Runnable{
private ShareData1 data1;
public MyRunnable2(ShareData1 data1){
this.data1 = data1;
}
public void run() {
data1.increment();
}
}
class ShareData1 /*implements Runnable*/{
/* private int count = 100;
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
count--;
}
}*/
private int j = 0;
private boolean bShouldSub = true;
public synchronized void increment(){
while(!bShouldSub){
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
for(int i=0;i<5;i++){
j++;
System.out.println(j);
}
bShouldSub = false;
this.notify();
System.out.println("==================");
}
public synchronized void decrement(){
while(bShouldSub){
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
for(int i=0;i<5;i++){
System.out.println(j);
j--;
}
bShouldSub = true;
this.notify();
}
}
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* 1把共享数据封装在另外一个对象中，然后将这个对象逐一传递
给各个runnable对象，每个线程对共享数据的操作方法也分配
到那个对象本身上，这样容易实现针对该数据进行的各个操作
的互斥和通信
jdk1.5+中的线程间通信
* @author liyutao
*/
public class Test3 {
public static void main(String[] args) {
ShareData2 data2 = new ShareData2();
new Thread(new MyRunnable4(data2)).start();
new Thread(new MyRunnable3(data2)).start();
}
}
class MyRunnable3 implements Runnable{
private ShareData2 data2;
public MyRunnable3(ShareData2 data2){
this.data2 = data2;
}
public void run() {
data2.decrement();
}
}
class MyRunnable4 implements Runnable{
private ShareData2 data2;
public MyRunnable4(ShareData2 data2){
this.data2 = data2;
}
public void run() {
data2.increment();
}
}
class ShareData2 {
private int j = 0;
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();
private boolean bShouldSub = true;
public void increment(){
lock.lock();
try {
while(!bShouldSub){
try {
condition.await();
} catch (Exception e) {
e.printStackTrace();
}
}
for(int i=0;i<5;i++){
j++;
System.out.println(j);
}
bShouldSub = false;
condition.signal();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
lock.unlock();
}
System.out.println("==================");
}
public void decrement(){
lock.lock();
try {
while(bShouldSub){
try {
condition.await();
} catch (Exception e) {
e.printStackTrace();
}
}
for(int i=0;i<5;i++){
System.out.println(j);
j--;
}
bShouldSub = true;
condition.signal();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
lock.unlock();
}
}
}
public class TestSix {
private int j;
public static void main(String[] args) {
TestSix tt=new TestSix();
Inc inc=tt.new Inc();
Dec dec=tt.new Dec();
for(int i=0;i<2;i++){
Thread t=new Thread(inc);
t.start();
t=new Thread(dec);
t.start();
}
}
class Dec implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
for(int i=0;i<5;i++){
dec();
}
}
}
class Inc implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
for(int i=0;i<5;i++){
inc();
}
}
}
private synchronized void dec(){
j--;
System.out.println(Thread.currentThread().getName()+"-dec="+j);
}
private synchronized void inc(){
j++;
System.out.println(Thread.currentThread().getName()+"-inc="+j);
}
}
文章浏览阅读1.3w次，点赞14次，收藏25次。最近研究了vue的官方文档,到组件自定义渲染函数时,对第二个属性对象参数中的scopedSlots不太明白作用是什么,官网的案例也是一笔带过,于是连查带试算是明白了他的作用,这里记录一下,希望能帮到遇到相同问题的童鞋.先说一下函数中的$slots吧,这个用起来很简单,直接获取到组件中对应的插槽虚拟节点.this.$slots.插槽名称.废话少说,直接上代码:<div id="a..._this.$scopedslots
文章浏览阅读884次。本文将介绍领域驱动设计（DDD）战术模式中另一个非常重要的概念——领域服务。在前面两篇博文中，我们已经学习到了什么是值对象和实体，并且能够比较清晰的定位它们自身的行为。但是在某些时候，你..._领域服务需要用到的服务,放在什么位置
文章浏览阅读1.8k次。无法为JSP编译类:记录一个较少见的问题。在maven+ssm搭建中遇到的 org.apache.jasper.JasperException解决办法：（未细究其根本原因）将tomcat有tomcat7变更为tomcat8，启动项目可正产访问！_无法为jsp编译类:
文章浏览阅读1.7k次，点赞8次，收藏11次。是专为支持而设计的向量和向量，这使得它适用于各种基于的等应用。Qdrant 使用编写，即使在高负载下也能快速、可靠地工作。_qdrant
文章浏览阅读870次。Windows下备份和恢复1、备份①、用管理员身份启动cmd命令行②、进入mysql安装目录下bin文件夹内cd C:\Program Files\MySQL\MySQL Server 5.6\bin③、执行命令，回车，输入密码，备份文件在mysql bin文件下(xxx是数据库名,aaa是备份后的文件名，可以自己设置)mysqldump -u root -p xxx> aaa...._在cmd中执行mysql数据恢复语句
文章浏览阅读330次。数据产品经理修炼手册：从零基础到大数据产品实践IF you can't measure it, you can't improve it。-->意思是：如果你无法衡量，你就无法增长。数据产品：是可以发挥数据价值去辅助用户做更优决策的一种产品形式。它在用户的决策和行动过程中，可以提供更多的分析展现和数据洞察，让数据更直观、功效地驱动业务。从受众用户群体来看，数据产品可分为三类：1.企业内部使用的数据产品。2.企业针对公司推出的商业型数据产品。3.每个用户均可使用的数据产品。._4. if you can鈥檛 measure it, you can鈥檛 improve it
文章浏览阅读13次。首先,它采用全球通用的SIM卡标准,可以在全球范围内实现设备和网络的即插即用,实现方便快捷的连接。其次,电信物联卡具备稳定可靠的网络连接能力,不论是在城市还是偏远的乡村,不论是低功耗设备还是高频传输设备,都能提供高质量的网络服务。在智慧城市中,电信物联卡可以实现对公共设施的监控和管理,提高城市的运行效率和人们的生活质量。电信物联卡的普及和应用,不仅改变了我们的生活方式,也为未来的智能互联时代带来了无限可能。在当今信息化高速发展的时代,物联网作为技术创新的重要领域,正深刻地改变着我们的生活和工作方式。
文章浏览阅读2.3w次，点赞35次，收藏450次。随着互联网安全威胁的不断加剧，越来越多的企业，尤其是大企业需要雇佣持有CISSP证书的网络安全专家来保护自己的网站、APP、服务、数据不受侵害，不受破坏。_信息安全专业用到哪些软件
文章浏览阅读6.4k次，点赞4次，收藏7次。接到了一个需求，把正式数据库的A表（2.9万+）数据，导到测试数据库的A表中。数据量小，可以用“+”这种方式数据量大只能用dmp、sql文件、DBlink由于两个数据库的表空间不一样，dmp的方式先放弃。采用导出sql文件的形式，导出来后查看文件竟然中文乱码。导入数据库后也还是乱码状态。于是去网上查找到了解决办法。 1、首先产生问题的原因是，自己电脑环境变量NLS_LANG的值和数据库字符集不一致就造成了导入之后数据是乱码的问题。 2、解决办..._oracle导出sql中文乱码
文章浏览阅读186次。javaScript中的对象的继承方式摘自《JavaScript面向对象编程指南（第二版）》_12种继承方式
文章浏览阅读798次。我们都知道，java中的Map结构是key->value键值对存储的，而且根据Map的特性，同一个Map中 不存在两个Key相同的元素，而value不存在这个限制。换句话说，在同一个Map中Key是唯一的，而value不唯一。Map是一个接口，我们不能 直接声明一个Map类型的对象，在实际开发中，比较常用的Map性数据结构是HashMap和TreeMap,它们都是Map的直接子类。如果考虑到..._map键值类型不固定
文章浏览阅读301次，点赞4次，收藏7次。SMSSync - 简单易用的短信同步工具项目简介SMSSync 是一个开源的短信同步工具，它可以帮助您将手机上的短信同步到您的计算机或其他设备上。通过该工具，您可以轻松备份和管理短信，并能够随时随地访问它们。功能特性简单易用：SMSSync 的安装和配置过程非常简单，只需几步即可完成。跨平台支持：该工具支持 Windows、Mac 和 Linux 操作系统，可以在各种设备之间进行同步...