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

Question

[Надим]

Хочу, чтобы все последующие запуски функции давал результат самого первого запуска, но только в том случае если функция уже запущена и сейчас работает. То есть если есть работающий сейчас экземпляр функции мы не вызываем функцию снова, а просто берем результат этого самого работающего экземпляра, когда он (результат) будет готов.

Мой вариант с использованием глобалки и промисов:

Пример

function test() {
	
	if (typeof test_promise == 'undefined') {
		
		test_promise = new Promise(function(returnPromiseResult) {
			
			setTimeout(function() {
				
				test_promise = undefined;
				returnPromiseResult(new Date().getTime());
				
			}, 5000);
			
		});
		
		return test_promise;
		
	}
	
	else {
		
		return test_promise;
		
	}
	
}

Но может есть способы получше?

Answer 1

[Сергей Сергей]

Вы чо ребята?! Это же debounce с кешем результата.

Comments

[Надим]

Я знал, я жопой чуял, что изобретаю велосипед!) Хорошо хоть ума хватило спросить здесь. Спасибо за наводку, теперь знаю, что есть нативное решение.

https://learn.javascript.ru/task/debounce

P. S. Хотя нет, смотрю я щас, это не совсем то, чего хочу. Поторопился.

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

[Сергей Сергей]

Надим Закиров, Надо будет только выбрать режим с первым немедленным запуском, а потом ожидание для остальных, потому что обычно первый запуск тоже откладывается, а результат же нужен сразу. Trottle ещё есть, он поближе к требуемому. Но суть у них похожая, да.

[Надим]

Сергей Сергей, а если не сложно, можете простой пример сорудить? Я бы погонял в консоли, чтобы понять как оно будет с декораторами работать.

[Сергей Сергей]

Надим Закиров,

function debounce( f, delay = 50 ) {
  let t, r, c = false;
  const rescollect = ( ...b ) => { r = f.call( ...b ) }
  return function( ...a ) {
    if( !c ) rescollect( this, ...a ), c = true;
    clearTimeout( t );
    t = setTimeout( rescollect, delay, this, ...a );
    return r;
  }
}

Это так, на скорую руку, баги не ловил, потестил на ((a,b)=>a+b).

[WbICHA]

но только в том случае если функция уже запущена и сейчас работает.

Если функция асинхронная, то как бы промисы, программа подождёт, а если нет, то пока функция не выполнится, программа дальше не пойдёт.

[Надим]

WbICHA, ну да, предполагается что функция асинхронная, если результат не сразу отдает) Вариант с промисами я пока и использую как основной, но если вдруг пойму, что можно сделать лучше, перепишу.

[Сергей Сергей]

Надим Закиров, давным давно Как запретить одновременный вызов функции? , там был ответ от кого-то на промисах, который сейчас исчез, может кураторы восстановят, тоже можно приспособить как утилиту для функций.

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

Answer 2

[Егор Данченко]

Создайте класс и используйте паттерн Singleton.
Можно, конечно, реализовать и функцию, но способы достаточно костыльные. Правильное решение - класс с реализованным паттерном.
Реализация функции, только нужно запомнить состояние самого 1 вызова функции:

var something = (function() {
    var executed = false;
    return function() {
        if (!executed) {
            executed = true;
            // do something
        }
    };
})();
something(); // "do something" happens
something(); // nothing happens

Comments

[Надим]

Ничего не понял, но разберусь. Подожду еще решений, если более никто не напишет, отмечу ваш вариант решением. Спасибо за ответ.

Answer 3

[Александр]

Речь о чём-то похожем?

const singleBusinessLogic = (() => {
  let isBusy = false;
  let promise = null;
  let done = null;
  let failure = null;
  
  return (id) => {
    if (!isBusy) {
      isBusy = true;
      promise = new Promise((resolve, reject) => ([done, failure] = [resolve, reject]));
      
      fetch(`https://jsonplaceholder.typicode.com/users/${id}`)
        .then(response => response.json())
        .then(done)
        .catch(failure)
        .finally(() => (isBusy = false));
    }
    
    return promise;
  };
})();

(async () => {
  console.log(await singleBusinessLogic(1)); // { ..., name: 'Leanne Graham', ... }
  console.log(await singleBusinessLogic(2)); // { ..., name: 'Leanne Graham', ... }
  setTimeout(async () => {
    console.log(await singleBusinessLogic(3)); // { ..., name: 'Clementine Bauch', ... }
    console.log(await singleBusinessLogic(4)); // { ..., name: 'Clementine Bauch', ... }
  });
})();

Или хотите возвращать результат только самого первого вызова?

Comments

[Надим]

Сори, не могу осознать ваш код, у меня проблемы с новым стилем)

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

Как сделать это на промисах я знаю, но может есть еще способы?

[Александр]

Надим Закиров, Можно на функциях обратного вызова.

const singleBusinessLogic = (function () {
  const pending = [];
  
  function finish(error, response) {
    pending.forEach(callback => callback(error, response));
    pending.length = 0;
  }
  
  return function (id, callback) {
    if (pending.length === 0) {
      fetch(`https://jsonplaceholder.typicode.com/users/${id}`)
        .then(response => response.json())
        .then(response => finish(null, response))
        .catch(error => finish(error));
    }
    pending.push(callback);
  };
})();

singleBusinessLogic(1, (error, data) => {
  if (!error) {
    console.log(data);
  }
});
singleBusinessLogic(2, (error, data) => {
  if (!error) {
    console.log(data);
  }
});

setTimeout(function () {
  singleBusinessLogic(3, (error, data) => {
    if (!error) {
      console.log(data);
    }
  });
  singleBusinessLogic(4, (error, data) => {
    if (!error) {
      console.log(data);
    }
  });
}, 1000);

[Надим]

Александр, хм, интересно, завести массив чтобы собирать колбеки, а когда будет результат запустить все колбеки разом. Только pending у нас же локальная переменная, разве так оно заработает корректно?

[Александр]

Надим Закиров, А там IIFE.