Java 顺序但同时运行

Question

这可能看起来很愚蠢，但它是否可以按顺序运行但也可以同时使用线程？例如看下面的代码：

public void processMessage(Socket socket) {
     char[] data = buildData(socket.getInputStream());
     int primaryKey = saveRecord(data);
     // do something else
}

public char[] buildData(InputStream inputStream) {
    return new char[5];
}

public int saveRecord(char[] data) {
   // save to database and return primary key
}

Runnable runnable = new Runnable() {
   public void run() {
        processMessage(socket.getInputStream());
   }
};
new Thread(runnable).start();

Runnable runnable2 = new Runnable() {
   public void run() {
       processMessage(socket.getInputStream());
   }
};
new Thread(runnable2).start();

我要做的是启动一个线程并执行全套方法，然后另一个线程启动并完全完成。这是因为我收到了一些数据，读取了数据，插入到数据库中，还有其他事情，但想避免数据库更新并发问题。

其实这是一个TCP应用，数据来自socket，数据不会立即到达。在我有一个单线程应用程序之前，但由于应用程序运行速度太慢并且来自套接字的数据没有到达之前，我引入了线程。现在全套数据都在TCP Socket上，但我想避免数据库并发问题。

以上仅为示例代码。

我了解线程的基础知识，并且我知道每个线程都有自己的堆栈，但我想正确地保持数据库插入/更新以避免任何数据冲突。

编辑：

private ServerSocket serverSocket;
private Socket socket;

public void acceptData() {
      serverSocket = new ServerSocket("somePort");
      socket = serverSocket.accept();
      Runnable runnable = new Runnable() {
          public void run() {
              processMessage(socket.getInputStream());
          }
      };
      new Thread(runnable).start(); 
}

这就是我正在做的。在每个循环中，我都会创建一个新线程，这样套接字就不会被阻塞，并且会在线程被并发管理的同时继续发送数据。

Answer 1

它看起来是一个经典的生产者/消费者模式，对吧？

用一个信号量同步两个线程看起来是可行的。

private Object semaphore = new Object();

public void processMessage(Socket socket) {
    synchronize(semaphore) {
        char[] data = buildData(socket.getInputStream());
        int primaryKey = saveRecord(data);
        // do something else
    }
}

public char[] buildData(InputStream inputStream) {
    return new char[5];
}

public int saveRecord(char[] data) {
    // save to database and return primary key
}

Runnable runnable = new Runnable() {
    public void run() {
        processMessage(socket.getInputStream());
    }
};
new Thread(runnable).start();

Runnable runnable2 = new Runnable() {
    public void run() {
        processMessage(socket.getInputStream());
    }
};
new Thread(runnable2).start();

有了这个实现，第一个接收消息的线程将启动 processMessage 执行，我们将停止另一个线程的执行，直到它完成。

这是你要找的吗？