java - 如何在单例模式中同步两个方法

Question

我已经根据单例模式创建了一个数据库对象。数据库对象包含 2 个方法:connect() 和 update()。

更新应该以多线程方式运行，这意味着我无法将 synchronized 放入 update 方法签名中(我希望用户同时访问它，而不是一次访问一个)。

我的问题是我想确保 2 个场景符合以下流程:

1. 线程 1 (user1) 是第一个创建数据库实例的线程 2 (user2) 正在调用 connect() 和 update() 方法连接到此数据库 - 不应给出 NullPointerException，即使当 user2 执行 update() 时，来自 user1 的连接尚未完成。

2. update() 不应包含 synchronized (由于我上面提到的原因)。感谢所有帮助者!

辛格尔顿数据库

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

    public class SingeltonDB {
        private static DBconnImpl db = null;
        private static SingeltonDB singalDb = null;
          Lock dbLock;

        private SingeltonDB(String username, String password) {
            db = new DBconnImpl();
        }

        public static boolean isOpen() {
            return (db != null);
        }

        public synchronized static SingeltonDB getInstance(String username,
                String password) throws Exception {

            if (db != null) {
                throw (new Exception("The database is  open"));
            } else {
                System.out.println("The database is now open");
                singalDb = new SingeltonDB(username, password);
            }
            db.connect(username, password);
            System.out.println("The database was connected");

            return singalDb;
        }

        public synchronized static SingeltonDB getInstance() throws Exception {
            if (db == null) {
                throw (new Exception("The database is not open"));
            }

            return singalDb;
        }

        public void create(String tableName) throws Exception {
            dbLock = new ReentrantLock();
            dbLock.lock();
            db.create(tableName);
            dbLock.unlock();
        }

        public  User query(String tableName, int rowID) throws Exception {
            if (db == null) {
                System.out.println("Error: the database is not open");
                return null;
            }
            return (db.query(tableName, rowID));
        }

        public  void update(String tableName, User user) throws Exception {
            if (db == null) {
                System.out.println("Error: the database is not open");
                return;
            }
            db.update(tableName, user);
        }

    }

主要

public class Main {
    public static void main(String[] args) throws Exception {

        Creator cr= new Creator(new UserContorller());
        Thread t1 = new Thread(cr);
        t1.start();
        Producer pr = new Producer(new UserContorller());
        Thread t2 = new Thread(pr);
        t2.start();

        /*
         * Consumer cn = new Consumer(new UserContorller()); Thread t2 = new
         * Thread(cn); t2.start();
         */
    }
}

class Creator implements Runnable {
    UserContorller uc;

    public Creator(UserContorller uc) {
        this.uc = uc;
    }

    @Override
    public void run() {
        try {
            uc = new UserContorller("MyAccount", "123");
            uc.createTable("table1");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

class Producer implements Runnable {
    UserContorller uc;

    public Producer(UserContorller uc) {
        this.uc = uc;
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            try {
                uc.saveUser("table1", i, "User", i);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

class Consumer implements Runnable {
    UserContorller uc;

    public Consumer(UserContorller uc) {
        this.uc = uc;
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            try {
                System.out.println(uc.getUser("table1", i));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

Answer 1

注意:下面的帖子是从使用相同凭据(对他们隐藏)连接到数据库的两个用户的角度编写的。如果用户使用不同的凭据，则单例数据库对象的想法是没有目的的，每个用户都应该有自己的连接对象，当然，然后连接详细信息通过程序中代表用户的任何内容从用户传递到数据库(此处显然是线程实例)。

您提供的实现中的主要问题是 getinstance 方法要求其调用者了解连接详细信息，或者假设连接已经完成。但是线程不能也不应该提前知道数据库是否已经打开——从设计角度来说，让它们承担显式打开数据库的责任是一个错误。这些线程是工作线程，它们不应该关心数据库配置细节。

处理这种情况的唯一明智的方法是让 Db 对象直接保存这些配置参数，或者更好的是另一个负责提供它的对象(它是 factory 模式)。

但是，如果您希望代码首先以最小的更改工作，请摆脱参数较少的 getinstance 方法，让任何需要 Db 对象的线程使用该方法的剩余变体，传递沿着正确的参数，并将其更改为返回实例(如果存在)，否则创建实例，而不会引发异常。我相信这就是@Dima 在他的回答中试图解释的内容。