Помогите не знаю как реализовать такое на С#

[lbvf65]

Чтобы поставить С# первым кубиком и он отработал лиж при перезапуске шаблона 1 раз (в первом инстансе)
и
Чтобы поставить С# последним кубиком и он отработал 1 раз (в последнем инстансе)

Пожалуйста помогите знающие люди

Надо для проекта и не могу реализовать

Заранее спасибо за любую помощь

 

[doc]

ну первый не сложно. в локе просто идет доступ к глобалке и если там нет кодового слова - прописать его и этот поток будет первым и будет выполнять нужную штуку. Остальные потоки будут находить в глобалке кодовое слово и сливаться.
Тоже самое и с завершением, только наоборот. Главный вопрос в том, как определять, что инстанс последний? Ну и еще куча мелких нюансов, которые тоже придётся продумывать

 

[lbvf65]

Спасибо как я сам не додумался

 

[BAZAg]

Чтобы поставить С# первым кубиком и он отработал лиж при перезапуске шаблона 1 раз (в первом инстансе)
и
Чтобы поставить С# последним кубиком и он отработал 1 раз (в последнем инстансе)

Пожалуйста помогите знающие люди

Надо для проекта и не могу реализовать

Заранее спасибо за любую помощь

Создаем список.
Каждый инстанс получает количество строк в списке.
Если в списке 0 строк - значит это первый инстанс - добавил строчку в список.
Во входящих настройках ставим максимальное количество инстансов.
Каждый поток сверяет количество строчек в списке с этим значением - если значение равно - значит это последний инстанс.

И да при завершении любого инстанса - он должен удалить строчку со значением, которое добавил в список.
Таким образом при завершении всех - список будет пустым.

На вариант...

 

[lbvf65]

Создаем список.
Каждый инстанс получает количество строк в списке.
Если в списке 0 строк - значит это первый инстанс - добавил строчку в список.
Во входящих настройках ставим максимальное количество инстансов.
Каждый поток сверяет количество строчек в списке с этим значением - если значение равно - значит это последний инстанс.

И да при завершении любого инстанса - он должен удалить строчку со значением, которое добавил в список.
Таким образом при завершении всех - список будет пустым.

На вариант...

Спасибо

 

[Roman48]

https://zennolab.com/discussion/threads/globalnaja-peremennaja-i-mnogopotok.38083/post-284162

lock(SyncObject) {
  try {
  var gb_count = project.GlobalVariables["threads", "variable_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("threads", "variable_name", 1);
  return 1;
  }
}


lock(SyncObject){
    project.GlobalVariables.SetVariable("threads", "variable_name", 0);
}

Это если несколько потов, например, у меня есть парсер, парсит много сайтов, я так на каждый сайт по 5 потов выделяю.
Вот реализация Владимера https://zennolab.com/discussion/threads/shablon-oxranjajuschij-lokker-ili-kak-mozhno-zalochit-bloki-kubikov.51566/
Как раз для одного потока

lock(SyncObject) {
project.GlobalVariables.SetVariable("глобал", "shab_name", 0);
return "можно заходить другим";
}

lock(SyncObject)] {
  if(project.GlobalVariables["глобал", "shab_name"].Value==0){
project.GlobalVariables.SetVariable("глобал", "shab_name", 1);
    return "зашёл 1 поток";
}
    else throw new Exception();

}

Я делаю так, в уведомление переменную прописываю {-GlobalVariable.глобал.shab_name-} если получаю ошибку, делаю вход и создается переменная,

 

[doc]

https://zennolab.com/discussion/threads/globalnaja-peremennaja-i-mnogopotok.38083/post-284162

lock(SyncObject) {
  try {
  var gb_count = project.GlobalVariables["threads", "variable_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("threads", "variable_name", 1);
  return 1;
  }
}


lock(SyncObject){
    project.GlobalVariables.SetVariable("threads", "variable_name", 0);
}

Это если несколько потов, например, у меня есть парсер, парсит много сайтов, я так на каждый сайт по 5 потов выделяю.
Вот реализация Владимера https://zennolab.com/discussion/threads/shablon-oxranjajuschij-lokker-ili-kak-mozhno-zalochit-bloki-kubikov.51566/
Как раз для одного потока

lock(SyncObject) {
project.GlobalVariables.SetVariable("глобал", "shab_name", 0);
return "можно заходить другим";
}

lock(SyncObject)] {
  if(project.GlobalVariables["глобал", "shab_name"].Value==0){
project.GlobalVariables.SetVariable("глобал", "shab_name", 1);
    return "зашёл 1 поток";
}
    else throw new Exception();

}

Я делаю так, в уведомление переменную прописываю {-GlobalVariable.глобал.shab_name-} если получаю ошибку, делаю вход и создается переменная,
Посмотреть вложение 80594

работайте с SyncObject осторожно. В каждом новом участке кода (или в сниппете) он новый, и блокировка не одна и та же

 

[Roman48]

работайте с SyncObject осторожно. В каждом новом участке кода (или в сниппете) он новый, и блокировка не одна и та же

Подскажешь, пожалуйста, как в код добавить сравнение if ?

lock(SyncObject) {
  try {
  var gb_count = project.GlobalVariables["threads", "variable_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("threads", "variable_name", 1);
  return 1;
  }
}

if(project.GlobalVariables["глобал", "shab_name"].Value<=5)

 

[doc]

Подскажешь, пожалуйста, как в код добавить сравнение if ?

lock(SyncObject) {
  try {
  var gb_count = project.GlobalVariables["threads", "variable_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("threads", "variable_name", 1);
  return 1;
  }
}

if(project.GlobalVariables["глобал", "shab_name"].Value<=5)

зависит от того, что ты хочешь

 

[Roman48]

зависит от того, что ты хочешь

Поток заходит, + 1 в переменой, но перед заходом сравнение например поставил 5 потоков, 6 поток уже не зайдет, а пойдет в другое место. Сейчас я это делаю кубиком if перед сниппетом.

 

[doc]

Поток заходит, + 1 в переменой, но перед заходом сравнение например поставил 5 потоков, 6 поток уже не зайдет, а пойдет в другое место. Сейчас я это делаю кубиком if перед сниппетом.

всё равно задача туманная. Здесь надо всё четко понимать мне, ибо блокировки надо четко расставить. Давай больше инфы и подробнее

 

[Roman48]

После захода, назовем его лок кубиков, вот после захода в лок кубика поток там работает по кругу, берет ссылки из файла с удалением и парсит. Я выделяю на каждый сайт по 5 потоков. В эту {-GlobalVariable.глобал.shab_name-} переменную записывается сколько потоков зашло, как поток заходит, в глобальной переменой {-GlobalVariable.глобал.shab_name-} цифра увеличивается на один.
Сейчас может зайти хоть 100 поток. Нужно перед заходом, сразу после lock(SyncObject) { сделать условие if(project.GlobalVariables["глобал", "shab_name"].Value<=5) если в переменой {-GlobalVariable.глобал.shab_name-} цифра 5 поток уже кубик не пройдет, уйдет по ошибке, цель не допустить парсинга больше 5 поток на один сайт.

lock(SyncObject) {
  try {
  var gb_count = project.GlobalVariables["глобал", "shab_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("глобал", "shab_name", 1);
  return 1;
  }
}

if(project.GlobalVariables["глобал", "shab_name"].Value<=5)

Сейчас у меня такая конструкция

 

[volody00]

Подскажешь, пожалуйста, как в код добавить сравнение if ?

if(Convert.ToInt32(project.GlobalVariables["глобал", "shab_name"].Value)>5)
{
    //иди по красной
    return null;
}

 

[Roman48]

if(Convert.ToInt32(project.GlobalVariables["глобал", "shab_name"].Value)>5)
{
    //иди по красной
    return null;
}

Работает спасибо. Код тут оставлю, может кому то пригодиться.

lock(SyncObject) {
if(Convert.ToInt32(project.GlobalVariables["глобал", "shab_name"].Value)>5)
{
    //иди по красной
    return null;
}   
  try {
  var gb_count = project.GlobalVariables["глобал", "shab_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("глобал", "shab_name", 1);
  return 1;
  }
}

 

[Roman48]

Подскажешь как тут сделать условие, поток один заходит, и на выходе в переменную пишет время, а другой поток может зайти если только пройдет время 10 минут?

Спасибо не первый раз ты мне помогаешь.

lock(SyncObject) {
  if(project.GlobalVariables["глобал", "shab_name"].Value=="2021 17:53:29"){
project.GlobalVariables.SetVariable("глобал", "shab_name", "2021 17:53:29");
    return "зашёл 1 поток";
}
    else throw new Exception();

}

Так вроде работает, но нужно с разницей 10 минут

 

[doc]

Работает спасибо. Код тут оставлю, может кому то пригодиться.

lock(SyncObject) {
if(Convert.ToInt32(project.GlobalVariables["глобал", "shab_name"].Value)>5)
{
    //иди по красной
    return null;
}  
  try {
  var gb_count = project.GlobalVariables["глобал", "shab_name"];
  return ++gb_count.Value;
  }
  catch (KeyNotFoundException ex) {
  project.GlobalVariables.SetVariable("глобал", "shab_name", 1);
  return 1;
  }
}

в твоём варианте после перезапуска зенно всегда будет по красной уходить
пробуй этот вариант

lock(SyncObject) { 
    try {
        var gb_count = project.GlobalVariables["глобал", "shab_name"];
        if(Convert.ToInt32(gb_count.Value) > 5)
        {
            //иди по красной
            throw new Exception();
        }   
          
        return ++gb_count.Value;
    }
    catch (KeyNotFoundException ex) {
        project.GlobalVariables.SetVariable("глобал", "shab_name", 1);
        return 1;
    }
}

 

[volody00]

Так вроде работает, но нужно с разницей 10 минут

формат даты только надо вида: 28.07.2021 20:16:08

lock(SyncObject) {
    DateTime time;
    try{
        time = Convert.ToDateTime(project.GlobalVariables["глобал", "shab_name"].Value);
    }
    catch{
        project.SendErrorToLog("Нужно исправить формат даты в переменной shab_name", true);
        return null;
    }
    
    //если текущее время больше чем время в глобальной переменной shab_name + 10 мин
    if(DateTime.Now > time.AddMinutes(10))
    {
        //запись текущего времени и выход по зеленой
        project.GlobalVariables.SetVariable("глобал", "shab_name", DateTime.Now.ToString());
        return "зашёл 1 поток";
    }
    else
    {
        //выход по красной
        throw new Exception("идем по красной");
    }
}

 

[Roman48]

работайте с SyncObject осторожно. В каждом новом участке кода (или в сниппете) он новый, и блокировка не одна и та же

Теперь дошло)

lock (project.GlobalVariables)
{

Получается что можно и на код C# делать лок

lock (project.Variables)

Сейчас проверил, код отрабатывает

 

[Phoenix78]

Теперь дошло)

lock (project.GlobalVariables)
{

Получается что можно и на код C# делать лок

lock (project.Variables)

Сейчас проверил, код отрабатывает
Посмотреть вложение 80917

что работает то ?
что этот код лочит ? локальную переменную в 1 потоке , когда они и так там приватная ? Какой в этом глубокий смысл ?

 

[Alexmd]

Сейчас проверил, код отрабатывает

Отрабатывает) Но какой смысл лочить то, что и так не видно другим потокам?

 

[Roman48]

что работает то ?
что этот код лочит ? локальную переменную в 1 потоке , когда они и так там приватная ? Какой в этом глубокий смысл ?

Наверно ты прав)

 

[doc]

Получается что можно и на код C# делать лок

до этого не на c# делал лок?)

 

[Roman48]

до этого не на c# делал лок?)

Об этом не знал, случайно увидел GlobalVariables и сразу догадался, что мне нужно.