Как к взаимному исключению через сеть?

I think you're looking for a database transaction. A transaction will isolate your changes from all other clients.

Update: Вы упомянули, что функция в настоящее время не записывает в базу данных. Если вы хотите мьютексировать эту функцию, вам потребуется центральное место для хранения текущего держателя мьютекса. База данных может работать для этого - просто добавьте новую таблицу, которая включает имя компьютера текущего владельца. Перед запуском функции проверьте эту таблицу.

Я думаю, что ваш вопрос может вызвать путаницу. Мьютексы должны быть связаны с защитой ресурсов. Если ваша функция не обращается к базе данных, то какой общий ресурс вы защищаете?

Conversely consider a message queue. As mentioned, the DB should manage all of this for you either in transactions or serial access to tables (ala MyISAM).

You can use Terracotta to implement such functionality, if you've got a Java stack.

In the past I have done the following:

1. Create a table that basically has two fields, function_name and is_running

2. I don't know what RDBMS you are using, but most have a way to lock individual records for update. Here is some pseduocode based on Oracle:

   BEGIN TRANS

   SELECT FOR UPDATE is_running FROM function_table WHERE function_name='foo';

   -- Check here to see if it is running, if not, you can set running to 'true'

   UPDATE function_table set is_running='Y' where function_name='foo';

   COMMIT TRANS

Now I don't have the Oracle PSQL docs with me, but you get the idea. The 'FOR UPDATE' clause locks there record after the read until the commit, so other processes will block on that SELECT statement until the current process commits.

Даже если ваша функция в настоящее время не использует базу данных, вы все равно можете решить проблему с помощью конкретной таблицы с целью синхронизации этой функции. Специфика будет зависеть от вашей БД и того, как она обрабатывает уровни изоляции и блокировки. Например, с SQL Server вы должны установить изоляцию транзакции на повторяющееся чтение, прочитать значение из строки блокировки и обновить его внутри транзакции. Не фиксируйте транзакцию, пока ваша функция не будет выполнена. Вы также можете использовать явные блокировки таблиц в транзакции в большинстве баз данных, что может быть проще. Это, вероятно, самое простое решение, учитывая, что вы уже используете базу данных.

Если вы не хотите полагаться на базу данных по какой-либо причине, вы можете написать простую службу, которая будет принимать TCP-соединения от вашего клиента. Каждый клиент запрашивал разрешение на запуск и возвращал ответ по завершении. Сервер сможет гарантировать, что только один клиент получит разрешение на запуск одновременно. Мертвые клиенты в конечном итоге разорвали TCP-соединение и были обнаружены, если у вас была правильная настройка сохранения активности.

Решение для очереди сообщений, предложенное Xepoch, также будет работать. Вы можете использовать что-то вроде MSMQ или Java Message Queue и иметь одно сообщение, которое будет действовать как маркер выполнения. Все ваши клиенты будут запрашивать сообщение, а затем репостить его, когда это будет сделано. Вы рискуете попасть в тупик, если клиент умрет до репоста, поэтому вам нужно будет разработать логику, чтобы обнаружить это, и это может усложниться.

Мертвые клиенты в конечном итоге разорвали TCP-соединение и были обнаружены, если у вас была правильная настройка сохранения активности.

Решение для очереди сообщений, предложенное Xepoch, также будет работать. Вы можете использовать что-то вроде MSMQ или Java Message Queue и иметь одно сообщение, которое будет действовать как маркер выполнения. Все ваши клиенты будут запрашивать сообщение, а затем репостить его, когда это будет сделано. Вы рискуете попасть в тупик, если клиент умрет до повторной публикации, поэтому вам нужно будет разработать логику, чтобы обнаружить это, и это может усложниться.

Мертвые клиенты в конечном итоге разорвали TCP-соединение и были обнаружены, если у вас была правильная настройка сохранения активности.

Решение для очереди сообщений, предложенное Xepoch, также будет работать. Вы можете использовать что-то вроде MSMQ или Java Message Queue и иметь одно сообщение, которое будет действовать как маркер выполнения. Все ваши клиенты будут запрашивать сообщение, а затем репостить его, когда это будет сделано. Вы рискуете попасть в тупик, если клиент умрет до репоста, поэтому вам нужно будет разработать логику, чтобы обнаружить это, и это может усложниться.

Все ваши клиенты будут запрашивать сообщение, а затем репостить его, когда это будет сделано. Вы рискуете зайти в тупик, если клиент умрет до повторной публикации, поэтому вам нужно будет разработать логику, чтобы обнаружить это, и это может усложниться.

Все ваши клиенты будут запрашивать сообщение, а затем репостить его, когда это будет сделано. Вы рискуете попасть в тупик, если клиент умрет до повторной публикации, поэтому вам нужно будет разработать логику, чтобы обнаружить это, и это может усложниться.

поместите код внутри транзакции - в приложение или, что лучше, внутри хранимой процедуры и вызовите хранимую процедуру. механизм транзакции изолирует код между вызывающими абонентами.