खास जानकारी
Skyframe StateMachine
, डिकॉन्स्ट्रक्ट किया गया फ़ंक्शन-ऑब्जेक्ट है, जो हेप में मौजूद होता है. जब ज़रूरी वैल्यू तुरंत उपलब्ध नहीं होती हैं, लेकिन उनका एसिंक्रोनस तरीके से आकलन किया जाता है, तो यह सुविधा1 बिना किसी अतिरिक्त शर्त के काम करती है और आकलन करती है. StateMachine
, इंतज़ार करते समय थ्रेड संसाधन को इस्तेमाल नहीं कर सकता. इसके बजाय, उसे निलंबित और फिर से शुरू करना पड़ता है. इस तरह डिकंस्ट्रक्शन, साफ़ तौर पर री-एंट्री पॉइंट दिखाता है,
ताकि पहले के कंप्यूटेशन को स्किप किया जा सके.
StateMachine
का इस्तेमाल, क्रम, शाखाओं, और स्ट्रक्चर्ड लॉजिकल एक साथ होने वाली प्रोसेस को दिखाने के लिए किया जा सकता है. साथ ही, इन्हें खास तौर पर Skyframe इंटरैक्शन के लिए बनाया गया है. StateMachine
को बड़े StateMachine
में कंपोज किया जा सकता है और सब-StateMachine
शेयर किए जा सकते हैं. निर्माण के आधार पर कॉन करंसी हमेशा पदानुक्रमिक होती है
और यह पूरी तरह लॉजिकल होती है. एक साथ चलने वाले हर सबटास्क, एक ही शेयर किए गए पैरंट SkyFunction थ्रेड में चलता है.
परिचय
इस सेक्शन में, java.com.google.devtools.build.skyframe.state
पैकेज में मौजूद StateMachine
के बारे में कम शब्दों में बताया गया है.
Skyframe के रीस्टार्ट होने के बारे में जानकारी
Skyframe एक ऐसा फ़्रेमवर्क है जो डिपेंडेंसी ग्राफ़ का पैरलल तरीके से आकलन करता है.
ग्राफ़ का हर नोड SkyFunction के मूल्यांकन के साथ मेल खाता है जिसमें
SkyKey अपने पैरामीटर तय करती है और SkyValue उसका नतीजा बताता है. कंप्यूटेशनल मॉडल ऐसा है कि SkyFunction, SkyKey से SkyValues को ढूंढ सकता है. इससे अतिरिक्त SkyFunctions का बार-बार होने वाला आकलन ट्रिगर होता है. अनुरोध की गई SkyValue पूरी तरह से तैयार न होने पर, उसे ब्लॉक करने के बजाय, null
getValue
का जवाब दिया जाता है. ऐसा इसलिए किया जाता है, ताकि थ्रेड को रोका न जा सके. SkyFunction को SkyValue के बजाय null
दिखाया जाता है, ताकि यह पता चल सके कि इनपुट मौजूद न होने की वजह से, SkyValue पूरी तरह से तैयार नहीं है.
पहले से अनुरोध की गई सभी SkyValues उपलब्ध होने पर, Skyframe SkyFunctions को रीस्टार्ट करता है.
SkyKeyComputeState
के आने से पहले, रीस्टार्ट को मैनेज करने का पारंपरिक तरीका यह था कि कैलकुलेशन को पूरी तरह से फिर से चलाया जाता था. हालांकि, इसकी जटिलता दोगुनी है, लेकिन इस तरह से लिखे गए फ़ंक्शन आखिर में पूरे हो जाते हैं, क्योंकि हर बार फिर से चलाने पर, कम लुकअप null
दिखाते हैं. SkyKeyComputeState
की मदद से, मैन्युअल तरीके से तय किए गए चेकपॉइंट डेटा को SkyFunction के साथ जोड़ा जा सकता है. इससे, डेटा को फिर से कैलकुलेट करने में लगने वाला समय बचता है.
StateMachine
ऐसे ऑब्जेक्ट हैं जो SkyKeyComputeState
के अंदर रहते हैं और स्काई फ़ंक्शन के रीस्टार्ट होने पर, वर्चुअल तौर पर सभी रीकंप्यूटेशन को खत्म करते हैं (यह मानते हुए कि SkyKeyComputeState
कैश मेमोरी से बाहर नहीं जाता है) सस्पेंड और फिर से एक्ज़ीक्यूशन हुक को दिखाकर, उसे फिर से चालू करते हैं.
SkyKeyComputeState
में स्टेटफ़ुल कैलकुलेशन
ऑब्जेक्ट-ओरिएंटेड डिज़ाइन के हिसाब से, डेटा वैल्यू के बजाय SkyKeyComputeState
में कैलकुलेट किए गए ऑब्जेक्ट को स्टोर करना सही होता है.
Java में, किसी व्यवहार को कैरी करने वाले ऑब्जेक्ट के बारे में कम से कम जानकारी, फ़ंक्शनल इंटरफ़ेस होती है. यह जानकारी काफ़ी होती है. StateMachine
की परिभाषा2, इस तरह की है:
@FunctionalInterface
public interface StateMachine {
StateMachine step(Tasks tasks) throws InterruptedException;
}
Tasks
इंटरफ़ेस, SkyFunction.Environment
से मिलता-जुलता है, लेकिन इसे एक साथ काम न करने के लिए डिज़ाइन किया गया है. साथ ही, यह एक साथ काम करने वाले सबटास्क के लिए भी काम करता है3.
step
की रिटर्न वैल्यू एक और StateMachine
है. इससे चरणों के क्रम की जानकारी, इंडक्टिव तरीके से दी जाती है. step
, StateMachine
के पूरा हो जाने पर DONE
वैल्यू दिखाता है. उदाहरण के लिए:
class HelloWorld implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
System.out.println("hello");
return this::step2; // The next step is HelloWorld.step2.
}
private StateMachine step2(Tasks tasks) {
System.out.println("world");
// DONE is special value defined in the `StateMachine` interface signaling
// that the computation is done.
return DONE;
}
}
इस फ़ंक्शन का इस्तेमाल करके, StateMachine
फ़ंक्शन के आउटपुट के बारे में बताया गया है.
hello
world
ध्यान दें कि step2
, StateMachine
के फ़ंक्शनल इंटरफ़ेस की परिभाषा को पूरा करता है. इसलिए, this::step2
का तरीका रेफ़रंस भी StateMachine
है. StateMachine
में अगली स्थिति तय करने का सबसे सामान्य तरीका, तरीकों के रेफ़रंस देना है.
आसानी से, कंप्यूटेशन को मोनोलिथिक फ़ंक्शन के बजाय StateMachine
चरणों में बांटकर, किसी कंप्यूटेशन को सस्पेंड करने और फिर से शुरू करने के लिए ज़रूरी हुक देता है. StateMachine.step
के वापस आने पर, निलंबन का एक साफ़ तौर पर बताया गया समय दिखता है. रिटर्न की गई StateMachine
वैल्यू से तय किया गया कॉन्टिन्यूएशन, फिर से शुरू करने का एक साफ़ तौर पर बताया गया पॉइंट है. इस तरह, फिर से कैलकुलेट करने से बचा जा सकता है, क्योंकि कैलकुलेशन को वहीं से शुरू किया जा सकता है जहां से छोड़ा गया था.
कॉलबैक, कंटिन्यूएशन, और एसिंक्रोनस कैलकुलेशन
तकनीकी भाषा में, StateMachine
एक कंटिन्यूशन की तरह काम करता है. इससे यह तय किया जाता है कि बाद में होने वाली कंप्यूटेशन की वैल्यू को एक्ज़ीक्यूट करना है या नहीं. ब्लॉक करने के बजाय, StateMachine
अपने-आप ही step
फ़ंक्शन से वापस लौटकर, निलंबित कर सकता है. इससे कंट्रोल, वापस Driver
इंस्टेंस पर ट्रांसफ़र हो जाता है. इसके बाद, Driver
किसी तैयार StateMachine
पर स्विच कर सकता है या Skyframe को फिर से कंट्रोल दे सकता है.
आम तौर पर, कॉलबैक और कंटिन्यूएशन को एक ही कॉन्सेप्ट के तौर पर देखा जाता है.
हालांकि, StateMachine
s इन दोनों के बीच अंतर बनाए रखता है.
- कॉलबैक - इससे पता चलता है कि एसिंक्रोनस कैलकुलेशन का नतीजा कहां सेव करना है.
- कंटिन्युएशन - एक्ज़ीक्यूशन की अगली स्थिति के बारे में बताता है.
एसिंक्रोनस कार्रवाई शुरू करते समय कॉलबैक की ज़रूरत होती है, जिसका मतलब है कि तरीके को कॉल करने के तुरंत बाद वास्तविक कार्रवाई नहीं होती है, जैसा कि SkyValue लुकअप के मामले में होता है. कॉलबैक को जितना हो सके उतना आसान रखना चाहिए.
कंटिन्यूएशन, StateMachine
की रिटर्न वैल्यू होती हैं. साथ ही, सभी असाइनोक्रोनस कैलकुलेशन के पूरा होने के बाद, कॉम्प्लेक्स एक्ज़ीक्यूशन को शामिल करते हैं.StateMachine
इस स्ट्रक्चर्ड तरीके से, कॉलबैक की प्रोसेस को मैनेज करना आसान हो जाता है.
Tasks
Tasks
इंटरफ़ेस, StateMachine
को SkyKey के हिसाब से SkyValues को लुकअप करने और एक साथ कई सबटास्क शेड्यूल करने के लिए एपीआई उपलब्ध कराता है.
interface Tasks {
void enqueue(StateMachine subtask);
void lookUp(SkyKey key, Consumer<SkyValue> sink);
<E extends Exception>
void lookUp(SkyKey key, Class<E> exceptionClass, ValueOrExceptionSink<E> sink);
// lookUp overloads for 2 and 3 exception types exist, but are elided here.
}
SkyValue लुकअप
StateMachine
, SkyValues देखने के लिए Tasks.lookUp
ओवरलोड का इस्तेमाल करते हैं. ये SkyFunction.Environment.getValue
और SkyFunction.Environment.getValueOrThrow
से मिलते-जुलते हैं. साथ ही, इनमें अपवाद को हैंडल करने के लिए, एक जैसे सेमेटिक्स का इस्तेमाल किया जाता है. लागू करने पर, लुकअप तुरंत नहीं किया जाता. इसके बजाय, ऐसा करने से पहले, जितने हो सके उतने लुकअप को एक साथ4 किया जाता है. हो सकता है कि वैल्यू तुरंत उपलब्ध न हो, जैसे कि Skyframe को फिर से शुरू करना ज़रूरी हो. इसलिए, कॉलर यह तय करता है कि कॉलबैक का इस्तेमाल करके, नतीजे में मिली वैल्यू का क्या करना है.
StateMachine
प्रोसेसर (Driver
और उसे
SkyFrame में जोड़कर) यह गारंटी देता है कि मान, अगली स्थिति शुरू होने से पहले
उपलब्ध हो गया है. इसका उदाहरण यहां दिया गया है.
class DoesLookup implements StateMachine, Consumer<SkyValue> {
private Value value;
@Override
public StateMachine step(Tasks tasks) {
tasks.lookUp(new Key(), (Consumer<SkyValue>) this);
return this::processValue;
}
// The `lookUp` call in `step` causes this to be called before `processValue`.
@Override // Implementation of Consumer<SkyValue>.
public void accept(SkyValue value) {
this.value = (Value)value;
}
private StateMachine processValue(Tasks tasks) {
System.out.println(value); // Prints the string representation of `value`.
return DONE;
}
}
ऊपर दिए गए उदाहरण में, पहला चरण new Key()
के लिए लुकअप करता है और this
को उपभोक्ता के तौर पर पास करता है. ऐसा इसलिए हो सकता है, क्योंकि DoesLookup
, Consumer<SkyValue>
को लागू करता है.
अनुबंध के मुताबिक, अगली स्थिति DoesLookup.processValue
शुरू होने से पहले, DoesLookup.step
के सभी लुकलअप पूरे हो जाते हैं. इसलिए, value
तब उपलब्ध होता है, जब इसे processValue
में ऐक्सेस किया जाता है.
सबटास्क
Tasks.enqueue
, लॉजिक के हिसाब से एक साथ कई सबटास्क को पूरा करने का अनुरोध करता है.
सबटास्क भी StateMachine
होते हैं और ये वही काम कर सकते हैं जो सामान्य StateMachine
कर सकते हैं. जैसे, बार-बार सबटास्क बनाना या SkyValues देखना.
lookUp
की तरह ही, स्टेट मशीन ड्राइवर यह पक्का करता है कि अगले चरण पर जाने से पहले सभी सबटास्क पूरे हो जाएं. इसका एक उदाहरण यहां दिया गया है.
class Subtasks implements StateMachine {
private int i = 0;
@Override
public StateMachine step(Tasks tasks) {
tasks.enqueue(new Subtask1());
tasks.enqueue(new Subtask2());
// The next step is Subtasks.processResults. It won't be called until both
// Subtask1 and Subtask 2 are complete.
return this::processResults;
}
private StateMachine processResults(Tasks tasks) {
System.out.println(i); // Prints "3".
return DONE; // Subtasks is done.
}
private class Subtask1 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
i += 1;
return DONE; // Subtask1 is done.
}
}
private class Subtask2 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
i += 2;
return DONE; // Subtask2 is done.
}
}
}
हालांकि, Subtask1
और Subtask2
लॉजिकल रूप से एक साथ होते हैं, लेकिन सब कुछ एक ही थ्रेड में चलता है. इसलिए, i
के "एक साथ कई" अपडेट को सिंक करने की ज़रूरत नहीं होती.
स्ट्रक्चर्ड कॉनकरेंसी
अगली स्थिति पर जाने से पहले, हर lookUp
और enqueue
का रिज़ॉल्व होना ज़रूरी है. इसका मतलब है कि एक साथ कई ऑब्जेक्ट, ट्री स्ट्रक्चर तक सीमित हैं. यहां दिए गए उदाहरण में दिखाए गए तरीके से, क्रम से लगाए गए5 एक साथ चलने वाले प्रोसेस बनाए जा सकते हैं.
UML से यह पता लगाना मुश्किल है कि एक साथ कई टास्क करने की सुविधा का स्ट्रक्चर, ट्री के तौर पर है. इसमें एक वैकल्पिक व्यू मौजूद है, जो पेड़ की बनावट को बेहतर ढंग से दिखाता है.
एक साथ कई काम करने के आंकड़ों की वजह समझना आसान है.
कॉम्पोज़िशन और कंट्रोल फ़्लो पैटर्न
इस सेक्शन में, एक से ज़्यादा StateMachine
बनाने के तरीके और कंट्रोल फ़्लो से जुड़ी कुछ समस्याओं के समाधान के उदाहरण दिए गए हैं.
क्रम से चलने वाली स्थितियां
यह कंट्रोल फ़्लो का सबसे सामान्य और आसान पैटर्न है. इसका उदाहरण, SkyKeyComputeState
में मौजूद स्टेटफ़ुल कैलकुलेशन में दिया गया है.
ब्रांचिंग
StateMachine
में शाखाओं की स्थितियां, रेगुलर Java कंट्रोल फ़्लो का इस्तेमाल करके अलग-अलग वैल्यू दिखाकर हासिल की जा सकती हैं. इसका उदाहरण नीचे दिया गया है.
class Branch implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
// Returns different state machines, depending on condition.
if (shouldUseA()) {
return this::performA;
}
return this::performB;
}
…
}
कुछ शाखाओं के लिए, जल्दी पूरा होने के लिए DONE
लौटाना आम बात है.
बेहतर क्रम में कंपोज़िशन
StateMachine
कंट्रोल स्ट्रक्चर में मेमोरी नहीं होती. इसलिए, कभी-कभी StateMachine
के सबटास्क के तौर पर परिभाषाएं शेयर करना मुश्किल हो सकता है. मान लें कि M1 और M2 StateMachine
, S और M1 को शेयर करते हैं. साथ ही, M1 और M2 क्रम <A, S, B> और <X, S, Y> क्रम हैं.StateMachine
समस्या यह है कि S को यह पता नहीं होता कि वह B पर जाना है या Y पर. साथ ही, StateMachine
s में कॉल स्टैक नहीं होता. इस सेक्शन में, ऐसा करने के लिए कुछ तकनीकों की समीक्षा की गई है.
टर्मिनल क्रम एलिमेंट के तौर पर StateMachine
इससे शुरुआती समस्या हल नहीं होती. यह सिर्फ़ तब क्रम से कॉम्पोज़ करने का तरीका दिखाता है, जब शेयर किया गया StateMachine
, क्रम में टर्मिनल होता है.
// S is the shared state machine.
class S implements StateMachine { … }
class M1 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
performA();
return new S();
}
}
class M2 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
performX();
return new S();
}
}
यह तब भी काम करता है, जब S खुद एक जटिल स्टेट मशीन हो.
क्रम से लिखने के लिए सबटास्क
सूची में जोड़े गए सबटास्क, अगले स्टेटस से पहले पूरे हो जाते हैं. इसलिए, कभी-कभी सबटास्क के काम करने के तरीके का थोड़ा 6 गलत इस्तेमाल किया जा सकता है.
class M1 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
performA();
// S starts after `step` returns and by contract must complete before `doB`
// begins. It is effectively sequential, inducing the sequence < A, S, B >.
tasks.enqueue(new S());
return this::doB;
}
private StateMachine doB(Tasks tasks) {
performB();
return DONE;
}
}
class M2 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
performX();
// Similarly, this induces the sequence < X, S, Y>.
tasks.enqueue(new S());
return this::doY;
}
private StateMachine doY(Tasks tasks) {
performY();
return DONE;
}
}
runAfter
इंजेक्शन
कभी-कभी, Tasks.enqueue
का गलत इस्तेमाल करना मुमकिन नहीं होता, क्योंकि S के लागू होने से पहले, अन्य सबटास्क या Tasks.lookUp
कॉल पूरे होने चाहिए. इस मामले में, S में runAfter
पैरामीटर को इंजेक्ट करके, S को यह बताया जा सकता है कि आगे क्या करना है.
class S implements StateMachine {
// Specifies what to run after S completes.
private final StateMachine runAfter;
@Override
public StateMachine step(Tasks tasks) {
… // Performs some computations.
return this::processResults;
}
@Nullable
private StateMachine processResults(Tasks tasks) {
… // Does some additional processing.
// Executes the state machine defined by `runAfter` after S completes.
return runAfter;
}
}
class M1 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
performA();
// Passes `this::doB` as the `runAfter` parameter of S, resulting in the
// sequence < A, S, B >.
return new S(/* runAfter= */ this::doB);
}
private StateMachine doB(Tasks tasks) {
performB();
return DONE;
}
}
class M2 implements StateMachine {
@Override
public StateMachine step(Tasks tasks) {
performX();
// Passes `this::doY` as the `runAfter` parameter of S, resulting in the
// sequence < X, S, Y >.
return new S(/* runAfter= */ this::doY);
}
private StateMachine doY(Tasks tasks) {
performY();
return DONE;
}
}
यह तरीका, सबटास्क का गलत इस्तेमाल करने से बेहतर है. हालांकि, इसे बहुत ज़्यादा इस्तेमाल करने पर, जैसे कि runAfter
के साथ कई StateMachine
को नेस्ट करने पर, कॉलबैक हेल की समस्या आ सकती है. इसके बजाय, क्रम से चलने वाले runAfter
को सामान्य क्रम से चलने वाले स्टेटस में बांटना बेहतर होता है.
return new S(/* runAfter= */ new T(/* runAfter= */ this::nextStep))
को इनके साथ बदला जा सकता है.
private StateMachine step1(Tasks tasks) {
doStep1();
return new S(/* runAfter= */ this::intermediateStep);
}
private StateMachine intermediateStep(Tasks tasks) {
return new T(/* runAfter= */ this::nextStep);
}
पाबंदी वाला विकल्प: runAfterUnlessError
इससे पहले के ड्राफ़्ट में, हमने runAfterUnlessError
को लागू करने के बारे में सोचा था, जो गड़बड़ी होने पर जल्द ही खत्म हो जाएगा. ऐसा इसलिए किया गया, क्योंकि गड़बड़ियों की जांच अक्सर दो बार की जाती है. एक बार उस StateMachine
से जिसका runAfter
रेफ़रंस है और एक बार runAfter
मशीन से.
कुछ विचार-विमर्श के बाद, हमने फ़ैसला लिया कि गड़बड़ी की जांच को डुप्लीकेट करने से ज़्यादा, कोड को एक जैसा रखना ज़्यादा ज़रूरी है. अगर runAfter
तरीका, tasks.enqueue
तकनीक के मुताबिक काम नहीं करता है, तो यह भ्रम की स्थिति पैदा करेगा. इसमें हमेशा गड़बड़ी की जांच करना ज़रूरी होता है.
सीधे तौर पर अधिकार देना
जब भी किसी स्टेटस में बदलाव होता है, तो मुख्य Driver
लूप आगे बढ़ता है.
समझौते के मुताबिक, स्टेटस आगे बढ़ने का मतलब है कि अगला स्टेटस लागू होने से पहले, पहले से लाइन में लगे सभी SkyValue के लुकअप और सबटास्क पूरे हो जाते हैं. कभी-कभी, किसी टास्क को किसी दूसरे व्यक्ति को सौंपने के लिए तय किए गए लॉजिक StateMachine
की वजह से, टास्क के किसी चरण को आगे बढ़ाना ज़रूरी नहीं होता या इससे काम का नतीजा नहीं मिलता. उदाहरण के लिए, अगर डेलिगेट का पहला step
, SkyKey लुकअप करता है, जिन्हें डेलिगेट करने वाले स्टेटस के लुकअप के साथ पैरलल किया जा सकता है, तो फ़ेज़ अडवांस उन्हें क्रम में कर देगा. नीचे दिए गए उदाहरण में दिखाया गया है कि सीधे तौर पर अधिकार सौंपना ज़्यादा सही हो सकता है.
class Parent implements StateMachine {
@Override
public StateMachine step(Tasks tasks ) {
tasks.lookUp(new Key1(), this);
// Directly delegates to `Delegate`.
//
// The (valid) alternative:
// return new Delegate(this::afterDelegation);
// would cause `Delegate.step` to execute after `step` completes which would
// cause lookups of `Key1` and `Key2` to be sequential instead of parallel.
return new Delegate(this::afterDelegation).step(tasks);
}
private StateMachine afterDelegation(Tasks tasks) {
…
}
}
class Delegate implements StateMachine {
private final StateMachine runAfter;
Delegate(StateMachine runAfter) {
this.runAfter = runAfter;
}
@Override
public StateMachine step(Tasks tasks) {
tasks.lookUp(new Key2(), this);
return …;
}
// Rest of implementation.
…
private StateMachine complete(Tasks tasks) {
…
return runAfter;
}
}
डेटा फ़्लो
पिछली चर्चा में, कंट्रोल फ़्लो को मैनेज करने पर फ़ोकस किया गया था. इस सेक्शन में, डेटा वैल्यू के प्रॉपेगेशन के बारे में बताया गया है.
Tasks.lookUp
कॉलबैक लागू करना
SkyValue के लुकरअप में Tasks.lookUp
कॉलबैक लागू करने का उदाहरण. इस सेक्शन में, एक से ज़्यादा SkyValues को मैनेज करने के तरीके के बारे में बताया गया है.
Tasks.lookUp
कॉलबैक
Tasks.lookUp
का तरीका, पैरामीटर के तौर पर कॉलबैक sink
लेता है.
void lookUp(SkyKey key, Consumer<SkyValue> sink);
इसे लागू करने के लिए, Java लैम्ब्डा फ़ंक्शन का इस्तेमाल करना सबसे सही तरीका होगा:
tasks.lookUp(key, value -> myValue = (MyValueClass)value);
जहां myValue
, लुकअप कर रहे StateMachine
इंस्टेंस का सदस्य वैरिएबल है. हालांकि, StateMachine
को लागू करने के दौरान Consumer<SkyValue>
इंटरफ़ेस को लागू करने की तुलना में, लैम्ब्डा को ज़्यादा मेमोरी आवंट करने की ज़रूरत होती है. जब कई ऐसे लुकअप होते हैं जिनमें वैल्यू का पता लगाना मुश्किल होता है, तब भी लैम्ब्डा फ़ंक्शन का इस्तेमाल किया जा सकता है.
Tasks.lookUp
में गड़बड़ी को मैनेज करने के लिए, SkyFunction.Environment.getValueOrThrow
जैसे ही ओवरलोड भी हैं.
<E extends Exception> void lookUp(
SkyKey key, Class<E> exceptionClass, ValueOrExceptionSink<E> sink);
interface ValueOrExceptionSink<E extends Exception> {
void acceptValueOrException(@Nullable SkyValue value, @Nullable E exception);
}
इसे लागू करने का उदाहरण नीचे दिया गया है.
class PerformLookupWithError extends StateMachine, ValueOrExceptionSink<MyException> {
private MyValue value;
private MyException error;
@Override
public StateMachine step(Tasks tasks) {
tasks.lookUp(new MyKey(), MyException.class, ValueOrExceptionSink<MyException>) this);
return this::processResult;
}
@Override
public acceptValueOrException(@Nullable SkyValue value, @Nullable MyException exception) {
if (value != null) {
this.value = (MyValue)value;
return;
}
if (exception != null) {
this.error = exception;
return;
}
throw new IllegalArgumentException("Both parameters were unexpectedly null.");
}
private StateMachine processResult(Tasks tasks) {
if (exception != null) {
// Handles the error.
…
return DONE;
}
// Processes `value`, which is non-null.
…
}
}
गड़बड़ी को मैनेज किए बिना लुकअप करने की तरह ही, StateMachine
क्लास के सीधे कॉलबैक को लागू करने से, लैम्बा फ़ंक्शन के लिए मेमोरी का ऐलोकेशन बचता है.
गड़बड़ी को मैनेज करने की सुविधा से ज़्यादा जानकारी मिलती है. हालांकि, गड़बड़ियों के प्रसार और सामान्य वैल्यू के बीच काफ़ी फ़र्क़ नहीं होता.
एक से ज़्यादा SkyValues का इस्तेमाल करना
अक्सर, एक से ज़्यादा SkyValue लुकअप की ज़रूरत होती है. SkyValue के टाइप को चालू करने से, ज़्यादातर मामलों में समस्या हल हो जाती है. यहां एक उदाहरण दिया गया है, जिसे प्रोटोटाइप के प्रोडक्शन कोड से आसान बनाया गया है.
@Nullable
private StateMachine fetchConfigurationAndPackage(Tasks tasks) {
var configurationKey = configuredTarget.getConfigurationKey();
if (configurationKey != null) {
tasks.lookUp(configurationKey, (Consumer<SkyValue>) this);
}
var packageId = configuredTarget.getLabel().getPackageIdentifier();
tasks.lookUp(PackageValue.key(packageId), (Consumer<SkyValue>) this);
return this::constructResult;
}
@Override // Implementation of `Consumer<SkyValue>`.
public void accept(SkyValue value) {
if (value instanceof BuildConfigurationValue) {
this.configurationValue = (BuildConfigurationValue) value;
return;
}
if (value instanceof PackageValue) {
this.pkg = ((PackageValue) value).getPackage();
return;
}
throw new IllegalArgumentException("unexpected value: " + value);
}
Consumer<SkyValue>
कॉलबैक को लागू करने की प्रोसेस को साफ़ तौर पर शेयर किया जा सकता है, क्योंकि वैल्यू टाइप अलग-अलग होते हैं. अगर ऐसा नहीं है, तो लैम्ब्डा-आधारित लागू करने या सही कॉलबैक लागू करने वाले पूरे इनर-क्लास इंस्टेंस पर वापस जाना मुमकिन है.
StateMachine
के बीच वैल्यू का प्रसार करना
अब तक, इस दस्तावेज़ में सिर्फ़ यह बताया गया है कि किसी सबटास्क में काम को कैसे व्यवस्थित किया जाए. हालांकि, सबटास्क को कॉलर को वैल्यू भी रिपोर्ट करनी होती हैं. सबटास्क लॉजिकल रूप से एसिंक्रोनस होते हैं. इसलिए, कॉलर को कॉलबैक का इस्तेमाल करके उनके नतीजों की जानकारी दी जाती है. इसे काम करने के लिए, सबटास्क एक सिंक इंटरफ़ेस तय करता है, जिसे उसके कंस्ट्रक्टर के ज़रिए इंजेक्ट किया जाता है.
class BarProducer implements StateMachine {
// Callers of BarProducer implement the following interface to accept its
// results. Exactly one of the two methods will be called by the time
// BarProducer completes.
interface ResultSink {
void acceptBarValue(Bar value);
void acceptBarError(BarException exception);
}
private final ResultSink sink;
BarProducer(ResultSink sink) {
this.sink = sink;
}
… // StateMachine steps that end with this::complete.
private StateMachine complete(Tasks tasks) {
if (hasError()) {
sink.acceptBarError(getError());
return DONE;
}
sink.acceptBarValue(getValue());
return DONE;
}
}
इसके बाद, कॉल करने वाले व्यक्ति का आईडी StateMachine
कुछ इस तरह दिखेगा.
class Caller implements StateMachine, BarProducer.ResultSink {
interface ResultSink {
void acceptCallerValue(Bar value);
void acceptCallerError(BarException error);
}
private final ResultSink sink;
private Bar value;
Caller(ResultSink sink) {
this.sink = sink;
}
@Override
@Nullable
public StateMachine step(Tasks tasks) {
tasks.enqueue(new BarProducer((BarProducer.ResultSink) this));
return this::processResult;
}
@Override
public void acceptBarValue(Bar value) {
this.value = value;
}
@Override
public void acceptBarError(BarException error) {
sink.acceptCallerError(error);
}
private StateMachine processResult(Tasks tasks) {
// Since all enqueued subtasks resolve before `processResult` starts, one of
// the `BarResultSink` callbacks must have been called by this point.
if (value == null) {
return DONE; // There was a previously reported error.
}
var finalResult = computeResult(value);
sink.acceptCallerValue(finalResult);
return DONE;
}
}
ऊपर दिए गए उदाहरण में कुछ चीज़ें दिखाई गई हैं. Caller
को अपने नतीजे वापस लागू करने होंगे और खुद का Caller.ResultSink
तय करना होगा. Caller
, BarProducer.ResultSink
कॉलबैक लागू करता है. फिर से शुरू होने पर, processResult
यह जांच करता है कि value
शून्य है या नहीं, ताकि यह पता लगाया जा सके कि कोई गड़बड़ी हुई है या नहीं. किसी सबटास्क या SkyValue लुकअप से आउटपुट स्वीकार करने के बाद, यह आम तौर पर दिखने वाला व्यवहार पैटर्न होता है.
ध्यान दें कि गड़बड़ी की जानकारी को ऊपर भेजने की सुविधा के मुताबिक, acceptBarError
को लागू करने पर, नतीजा तुरंत Caller.ResultSink
को भेज दिया जाता है.
टॉप-लेवल StateMachine
के विकल्पों के बारे में Driver
और SkyFunctions से ब्रिज करने में बताया गया है.
गड़बड़ी ठीक करना
Tasks.lookUp
कॉलबैक और StateMachines
के बीच वैल्यू को ट्रांसफ़र करने में, पहले से ही गड़बड़ियों को मैनेज करने के कुछ उदाहरण दिए गए हैं. InterruptedException
के अलावा, किसी और एक्सेप्शन को थ्रो नहीं किया जाता. इसके बजाय, उन्हें वैल्यू के तौर पर कॉलबैक के ज़रिए पास किया जाता है. ऐसे कॉलबैक में अक्सर एक्सक्लूज़िव-या सेमेंटेक्स होते हैं. इनमें वैल्यू या गड़बड़ी में से सिर्फ़ एक को पास किया जाता है.
अगले सेक्शन में, Skyframe की गड़बड़ियों को मैनेज करने के बारे में आसान, लेकिन अहम इंटरैक्शन के बारे में बताया गया है.
बबल करने में गड़बड़ी (--nokeep_going)
गड़बड़ी के बबल होने के दौरान, SkyFunction को रीस्टार्ट किया जा सकता है, भले ही अनुरोध किए गए सभी SkyValues उपलब्ध न हों. ऐसे मामलों में, Tasks
API समझौते की वजह से, अगली स्थिति कभी हासिल नहीं की जा सकेगी. हालांकि, StateMachine
को अब भी अपवाद को प्रसारित करना चाहिए.
अगला चरण पूरा हो सकता है या नहीं, इस बात पर ध्यान दिए बिना प्रोपगेशन होना ज़रूरी है. इसलिए, गड़बड़ी को मैनेज करने वाले कॉलबैक को यह टास्क ज़रूर करना चाहिए. किसी इनर StateMachine
के लिए,
यह पैरंट कॉलबैक को लागू करके किया जाता है.
सबसे ऊपर के StateMachine
लेवल पर, जो SkyFunction के साथ इंटरफ़ेस करता है. इस प्रोसेस को ValueOrExceptionProducer
के setException
तरीके को कॉल करके किया जा सकता है.
इसके बाद, ValueOrExceptionProducer.tryProduceValue
अपवाद दिखाएगा. भले ही, SkyValues मौजूद न हों.
अगर किसी Driver
का सीधे तौर पर इस्तेमाल किया जा रहा है, तो SkyFunction से भेजी गई गड़बड़ियों की जांच करना ज़रूरी है. भले ही, मशीन ने प्रोसेस पूरी न की हो.
इवेंट मैनेज करना
जिन SkyFunctions को इवेंट उत्सर्जित करने की ज़रूरत होती है उनके लिए, SkyKeyComputeState में एक StoredEventHandler
इंजेक्ट किया जाता है. इसके बाद, उन StateMachine
में इंजेक्ट किया जाता है जिनके लिए ज़रूरी होता है. पहले, Skyframe कुछ इवेंट को तब तक ड्रॉप करता था, जब तक उन्हें फिर से चलाया नहीं जाता. इस वजह से, StoredEventHandler
की ज़रूरत पड़ती थी. हालांकि, बाद में इस समस्या को ठीक कर दिया गया.
StoredEventHandler
इंजेक्शन को सुरक्षित रखा गया है, क्योंकि यह गड़बड़ी को हैंडल करने वाले कॉलबैक से जनरेट होने वाले इवेंट को लागू करने की प्रोसेस को आसान बनाता है.
Driver
s और SkyFunctions पर जोड़ना
Driver
की ज़िम्मेदारी, किसी तय रूट StateMachine
से शुरू होने वाले StateMachine
को लागू करने की होती है. StateMachine
, सबटास्क StateMachine
को बार-बार लाइन में जोड़ सकते हैं. इसलिए, एक Driver
कई सबटास्क मैनेज कर सकता है. ये सबटास्क, एक साथ कई टास्क करने की सुविधा की वजह से एक ट्री स्ट्रक्चर बनाते हैं. Driver
, बेहतर परफ़ॉर्मेंस के लिए सभी सबटास्क में SkyValue के लिए एक साथ कई लुकअप करता है.
Driver
के लिए, यहां दिए गए एपीआई के साथ कई क्लास बनाई गई हैं.
public final class Driver {
public Driver(StateMachine root);
public boolean drive(SkyFunction.Environment env) throws InterruptedException;
}
Driver
, पैरामीटर के तौर पर एक रूट StateMachine
लेता है. Driver.drive
को कॉल करने पर, StateMachine
को तब तक चलाया जाता है, जब तक Skyframe को रीस्टार्ट किए बिना ऐसा किया जा सकता है. StateMachine
के पूरा होने पर यह 'सही' दिखाता है. वहीं, 'गलत' दिखाता है. इससे पता चलता है कि सभी वैल्यू उपलब्ध नहीं हैं.
Driver
, StateMachine
की एक साथ चलने वाली स्थिति को बनाए रखता है. साथ ही, यह SkyKeyComputeState
में एम्बेड करने के लिए सही है.
Driver
को सीधे इंस्टैंशिएट करना
StateMachine
लागू करने के लिए, आम तौर पर कॉलबैक के ज़रिए नतीजे शेयर किए जाते हैं. Driver
को सीधे तौर पर इंस्टैंशिएट किया जा सकता है, जैसा कि नीचे दिए गए उदाहरण में दिखाया गया है.
Driver
को SkyKeyComputeState
के लागू होने के साथ-साथ, उससे जुड़े ResultSink
के लागू होने के साथ एम्बेड किया जाता है. ResultSink
के बारे में थोड़ी देर बाद बताया जाएगा. सबसे ऊपर के लेवल पर, कंप्यूटेशन के नतीजे के लिए State
ऑब्जेक्ट सही रिसीवर के तौर पर काम करता है, क्योंकि इसके Driver
से आउट रहने की गारंटी होती है.
class State implements SkyKeyComputeState, ResultProducer.ResultSink {
// The `Driver` instance, containing the full tree of all `StateMachine`
// states. Responsible for calling `StateMachine.step` implementations when
// asynchronous values are available and performing batched SkyFrame lookups.
//
// Non-null while `result` is being computed.
private Driver resultProducer;
// Variable for storing the result of the `StateMachine`
//
// Will be non-null after the computation completes.
//
private ResultType result;
// Implements `ResultProducer.ResultSink`.
//
// `ResultProducer` propagates its final value through a callback that is
// implemented here.
@Override
public void acceptResult(ResultType result) {
this.result = result;
}
}
नीचे दिया गया कोड, ResultProducer
को स्केच करता है.
class ResultProducer implements StateMachine {
interface ResultSink {
void acceptResult(ResultType value);
}
private final Parameters parameters;
private final ResultSink sink;
… // Other internal state.
ResultProducer(Parameters parameters, ResultSink sink) {
this.parameters = parameters;
this.sink = sink;
}
@Override
public StateMachine step(Tasks tasks) {
… // Implementation.
return this::complete;
}
private StateMachine complete(Tasks tasks) {
sink.acceptResult(getResult());
return DONE;
}
}
फिर, लेज़ी तरीके से नतीजे का पता लगाने के लिए इस्तेमाल किया गया कोड कुछ ऐसा दिख सकता है.
@Nullable
private Result computeResult(State state, Skyfunction.Environment env)
throws InterruptedException {
if (state.result != null) {
return state.result;
}
if (state.resultProducer == null) {
state.resultProducer = new Driver(new ResultProducer(
new Parameters(), (ResultProducer.ResultSink)state));
}
if (state.resultProducer.drive(env)) {
// Clears the `Driver` instance as it is no longer needed.
state.resultProducer = null;
}
return state.result;
}
Driver
को एम्बेड करना
अगर StateMachine
कोई वैल्यू दिखाता है और कोई अपवाद नहीं दिखाता है, तो Driver
को एम्बेड करना एक और तरीका है. इसका उदाहरण नीचे दिया गया है.
class ResultProducer implements StateMachine {
private final Parameters parameters;
private final Driver driver;
private ResultType result;
ResultProducer(Parameters parameters) {
this.parameters = parameters;
this.driver = new Driver(this);
}
@Nullable // Null when a Skyframe restart is needed.
public ResultType tryProduceValue( SkyFunction.Environment env)
throws InterruptedException {
if (!driver.drive(env)) {
return null;
}
return result;
}
@Override
public StateMachine step(Tasks tasks) {
… // Implementation.
}
SkyFunction में ऐसा कोड हो सकता है जो यहां दिया गया है. यहां State
, SkyKeyComputeState
का फ़ंक्शन टाइप है.
@Nullable // Null when a Skyframe restart is needed.
Result computeResult(SkyFunction.Environment env, State state)
throws InterruptedException {
if (state.result != null) {
return state.result;
}
if (state.resultProducer == null) {
state.resultProducer = new ResultProducer(new Parameters());
}
var result = state.resultProducer.tryProduceValue(env);
if (result == null) {
return null;
}
state.resultProducer = null;
return state.result = result;
}
StateMachine
को लागू करने के तरीके में Driver
को एम्बेड करना, स्काईफ़्रेम की सिंक्रोनस कोडिंग स्टाइल के लिए बेहतर है.
अपवाद पैदा करने वाली स्टेटमशीन
इसके अलावा, SkyKeyComputeState
-एम्बेड की जा सकने वाली ValueOrExceptionProducer
और ValueOrException2Producer
क्लास भी होती हैं. इनमें सिंक्रोनस SkyFunction कोड से मैच करने के लिए, सिंक्रोनस एपीआई होते हैं.
ValueOrExceptionProducer
ऐब्सट्रैक्ट क्लास में ये तरीके शामिल हैं.
public abstract class ValueOrExceptionProducer<V, E extends Exception>
implements StateMachine {
@Nullable
public final V tryProduceValue(Environment env)
throws InterruptedException, E {
… // Implementation.
}
protected final void setValue(V value) { … // Implementation. }
protected final void setException(E exception) { … // Implementation. }
}
इसमें एम्बेड किया गया Driver
इंस्टेंस शामिल होता है. यह ड्राइवर को एम्बेड करने में मौजूद ResultProducer
क्लास से काफ़ी मिलता-जुलता है. साथ ही, यह SkyFunction के साथ उसी तरह इंटरफ़ेस करता है. ResultSink
तय करने के बजाय,
इंप्लिकेशन में इनमें से कोई भी होने पर setValue
या setException
को कॉल किया जाता है.
जब दोनों मौजूद हों, तो अपवाद को प्राथमिकता दी जाती है. tryProduceValue
तरीका, एसिंक्रोनस कॉलबैक कोड को सिंक्रोनस कोड में जोड़ता है और सेट किए जाने पर एक अपवाद दिखाता है.
जैसा कि पहले बताया गया है, गड़बड़ी के बबल होने के दौरान, गड़बड़ी तब भी हो सकती है, जब मशीन का काम पूरा न हुआ हो. ऐसा इसलिए होता है, क्योंकि सभी इनपुट उपलब्ध नहीं होते. इसे ध्यान में रखते हुए, tryProduceValue
मशीन के काम पूरा होने से पहले ही, सेट की गई किसी भी अपवाद को दिखाता है.
आखिर में: कॉलबैक की सुविधा को हटाना
StateMachine
एसिंक्रोनस कंप्यूटेशन (हिसाब लगाना) करने का एक बेहतर, लेकिन बॉयलरप्लेट
का इस्तेमाल करके कंप्यूटेशन का तरीका है. Bazel कोड के कुछ हिस्सों में, खास तौर पर Runnable
s के तौर पर, ListenableFuture
को पास करने वाले कॉन्टिन्यूएशन का इस्तेमाल बहुत ज़्यादा किया जाता है. हालांकि, विश्लेषण के लिए इस्तेमाल होने वाले SkyFunctions में, कॉन्टिन्यूएशन का इस्तेमाल ज़्यादा नहीं किया जाता. विश्लेषण का ज़्यादातर हिस्सा सीपीयू पर निर्भर करता है और डिस्क I/O के लिए, असिंक्रोनस एपीआई काम के नहीं होते. आखिर में, कॉलबैक को ऑप्टिमाइज़ करना अच्छा होगा, क्योंकि इनमें सीखने की प्रक्रिया ज़्यादा होती है और इन्हें पढ़ना मुश्किल होता है.
Java वर्चुअल थ्रेड, सबसे बेहतर विकल्पों में से एक है. कॉलबैक लिखने के बजाय, सब कुछ सिंक्रोनस, ब्लॉकिंग कॉल से बदल दिया जाता है. ऐसा इसलिए किया जा सकता है, क्योंकि प्लैटफ़ॉर्म थ्रेड के मुकाबले, वर्चुअल थ्रेड रिसॉर्स को जोड़ना सस्ता होता है. हालांकि, वर्चुअल थ्रेड का इस्तेमाल करने पर भी, सिंक्रोनस ऑपरेशन को थ्रेड बनाने और सिंक करने के प्राइमिटिव से बदलना बहुत महंगा होता है. हमने StateMachine
से Java वर्चुअल थ्रेड पर माइग्रेशन किया. इससे विश्लेषण में लगने वाला समय बहुत ज़्यादा बढ़ गया. साथ ही, एंड-टू-एंड विश्लेषण में लगने वाला समय करीब तीन गुना बढ़ गया. वर्चुअल थ्रेड अब भी झलक के तौर पर उपलब्ध है. इसलिए, हो सकता है कि परफ़ॉर्मेंस बेहतर होने पर, इसे बाद में माइग्रेट किया जाए.
एक और तरीका यह है कि Loom के कोरुटाइन उपलब्ध होने का इंतज़ार करें. इसका फ़ायदा यह है कि साथ मिलकर मल्टीटास्किंग का इस्तेमाल करके, सिंक करने में लगने वाले समय को कम किया जा सकता है.
अगर इन सभी तरीकों से भी समस्या हल नहीं होती है, तो लो-लेवल बाइटकोड को फिर से लिखना भी एक सही विकल्प हो सकता है. ज़रूरत के मुताबिक ऑप्टिमाइज़ेशन करने पर, मैन्युअल तरीके से लिखे गए कॉलबैक कोड जैसी परफ़ॉर्मेंस मिल सकती है.
अन्य जानकारी
कॉलबैक नरक
कॉलबैक हेल, एसिंक्रोनस कोड में एक आम समस्या है. इसमें कॉलबैक का इस्तेमाल किया जाता है. इसका मतलब यह है कि अगले चरण को अगले चरण में ले जाना, पिछले चरण में ही नेस्ट किया गया है. अगर कई चरण हैं, तो यह नेस्टिंग काफ़ी गहरी हो सकती है. अगर कंट्रोल फ़्लो के साथ कोड का इस्तेमाल किया जाता है, तो कोड मैनेज नहीं किया जा सकेगा.
class CallbackHell implements StateMachine {
@Override
public StateMachine step(Tasks task) {
doA();
return (t, l) -> {
doB();
return (t1, l2) -> {
doC();
return DONE;
};
};
}
}
नेस्ट किए गए लागू करने के तरीकों का एक फ़ायदा यह है कि बाहरी चरण के स्टैक फ़्रेम को सुरक्षित रखा जा सकता है. Java में, कैप्चर किए गए लैम्ब्डा वैरिएबल को फ़ाइनल माना जाना चाहिए, ताकि ऐसे वैरिएबल का इस्तेमाल करना मुश्किल हो. डीप नेस्टिंग से बचने के लिए, मेथड रेफ़रंस को लैम्ब्डा के बजाय, कॉन्टिन्यूएशन के तौर पर दिखाया जाता है.
class CallbackHellAvoided implements StateMachine {
@Override
public StateMachine step(Tasks task) {
doA();
return this::step2;
}
private StateMachine step2(Tasks tasks) {
doB();
return this::step3;
}
private StateMachine step3(Tasks tasks) {
doC();
return DONE;
}
}
runAfter
इंजेक्शन पैटर्न का बहुत ज़्यादा इस्तेमाल करने पर भी कॉलबैक हेल की समस्या हो सकती है. हालांकि, क्रम से चले जाने वाले चरणों के साथ इंजेक्शन को शामिल करके, इससे बचा जा सकता है.
उदाहरण: चेन किए गए SkyValue लुकअप
अक्सर ऐसा होता है कि ऐप्लिकेशन लॉजिक के लिए, SkyValue लुकअप की डिपेंडेंट चेन की ज़रूरत होती है. उदाहरण के लिए, अगर दूसरा SkyKey, पहले SkyValue पर निर्भर करता है. इस बारे में आसानी से सोचने पर, यह एक जटिल, नेस्ट किए गए कॉलबैक स्ट्रक्चर में बदल जाएगा.
private ValueType1 value1;
private ValueType2 value2;
private StateMachine step1(...) {
tasks.lookUp(key1, (Consumer<SkyValue>) this); // key1 has type KeyType1.
return this::step2;
}
@Override
public void accept(SkyValue value) {
this.value1 = (ValueType1) value;
}
private StateMachine step2(...) {
KeyType2 key2 = computeKey(value1);
tasks.lookup(key2, this::acceptValueType2);
return this::step3;
}
private void acceptValueType2(SkyValue value) {
this.value2 = (ValueType2) value;
}
हालांकि, जारी रखने की सुविधा को तरीके के रेफ़रंस के तौर पर बताया गया है. इसलिए, कोड सभी स्टेट ट्रांज़िशन में प्रोसेस वाला दिखता है: step2
, step1
के बाद आता है. ध्यान दें कि यहां value2
असाइन करने के लिए, lambda का इस्तेमाल किया गया है. इससे कोड का क्रम, ऊपर से नीचे तक कैलकुलेशन के क्रम से मैच हो जाता है.
अन्य सलाह
समझने में आसान होना: प्लान लागू करने का क्रम
कोड को आसानी से समझने के लिए, कोशिश करें कि StateMachine.step
लागू करने के तरीके को एक्ज़ीक्यूशन के क्रम में और कोड में कोड में पास किए जाने के तुरंत बाद लागू करें. जहां कंट्रोल फ़्लो की शाखाएं होती हैं वहां ऐसा हमेशा नहीं किया जा सकता. ऐसे मामलों में अतिरिक्त टिप्पणियां मददगार हो सकती हैं.
उदाहरण: चेन किए गए SkyValue लुकअप में, ऐसा करने के लिए एक इंटरमीडिएट मैथड रेफ़रंस बनाया जाता है. इससे, पढ़ने में आसानी के लिए परफ़ॉर्मेंस में थोड़ी गिरावट आती है. हालांकि, इसकी वजह से ज़्यादा फ़ायदा मिल सकता है.
जनरेशनल हाइपोथीसिस
थोड़ी देर तक रहने वाले Java ऑब्जेक्ट, Java कचरा इकट्ठा करने वाले टूल की पीढ़ी से जुड़ी हाइपोथीसिस को तोड़ते हैं. इसे इस तरह से डिज़ाइन किया गया है कि यह कुछ समय के लिए रहने वाली या हमेशा रहने वाली चीज़ों के हिसाब से काम करे. परिभाषा के हिसाब से, SkyKeyComputeState
में मौजूद ऑब्जेक्ट इस अनुमान का उल्लंघन करते हैं. ऐसे ऑब्जेक्ट, जिनमें Driver
पर रूट किए गए, अब भी चल रहे सभी StateMachine
s का बना हुआ ट्री शामिल होता है, उनका जीवनकाल कुछ समय के लिए होता है. ऐसा इसलिए होता है, क्योंकि वे असाइनमेंट के साथ-साथ चलने वाले कैलकुलेशन के पूरा होने का इंतज़ार करते हुए, निलंबित रहते हैं.
JDK19 में यह समस्या कम है. हालांकि, StateMachine
का इस्तेमाल करने पर, कभी-कभी जीसी के समय में बढ़ोतरी देखी जा सकती है. ऐसा तब भी होता है, जब जनरेट किए गए असल ग़ैर-ज़रूरी डेटा में काफ़ी कमी आई हो. StateMachine
s का लाइफ़साइकल सामान्य होता है, इसलिए इन्हें पुराने जनरेशन के तौर पर प्रमोट किया जा सकता है. इससे, यह ज़्यादा तेज़ी से भर जाता है. इसलिए, इसे खाली करने के लिए ज़्यादा महंगे मेजर या फ़ुल जीसी की ज़रूरत पड़ती है.
शुरुआती सावधानी यह है कि StateMachine
वैरिएबल का इस्तेमाल कम किया जाए. हालांकि, हमेशा ऐसा करना मुमकिन नहीं होता. उदाहरण के लिए, ऐसा तब हो सकता है, जब एक से ज़्यादा राज्यों में वैल्यू की ज़रूरत हो. जहां संभव हो, वहां लोकल स्टैक step
वैरिएबल, यंग जनरेशन वैरिएबल होते हैं और इन्हें जीसी (गैबरैग कॉन्ट्रोलर) की मदद से आसानी से हटाया जा सकता है.
StateMachine
वैरिएबल के लिए, चीज़ों को सबटास्क में बांटना और StateMachine
s के बीच वैल्यू को प्रसारित करने के लिए सुझाए गए पैटर्न का पालन करना भी मददगार होता है. ध्यान दें कि पैटर्न को फ़ॉलो करते समय, सिर्फ़ चाइल्ड StateMachine
s के रेफ़रंस में, StateMachine
s के रेफ़रंस दिए जाते हैं, न कि पैरंट के तौर पर. इसका मतलब यह है कि जब बच्चे नतीजे के कॉलबैक का इस्तेमाल करके, नतीजे देते हैं और माता-पिता के डेटा को अपडेट करते हैं, तो बच्चे स्वाभाविक रूप से दायरे से बाहर हो जाते हैं और उन्हें जीसी (GC) का ऐक्सेस मिल जाता है.
आखिर में, कुछ मामलों में, पहले स्टेटस में StateMachine
वैरिएबल की ज़रूरत होती है, लेकिन बाद के स्टेटस में नहीं. जब यह पता चल जाए कि बड़े ऑब्जेक्ट की ज़रूरत नहीं है, तो उनके रेफ़रंस को शून्य पर सेट करना फ़ायदेमंद हो सकता है.
नाम की स्थितियां
किसी तरीके का नाम रखते समय, आम तौर पर उस तरीके में होने वाले
व्यवहार के लिए, तरीके का नाम रखा जा सकता है. StateMachine
में ऐसा करने का तरीका साफ़ तौर पर नहीं पता चलता, क्योंकि इसमें स्टैक नहीं होता. उदाहरण के लिए, मान लें कि कोई तरीका foo
किसी सब-तरीके bar
को कॉल करता है. StateMachine
में, इसे foo
के बाद bar
के क्रम में बदला जा सकता है. foo
में अब bar
शामिल नहीं है. इस वजह से, राज्यों के लिए तरीकों के नाम सीमित हो जाते हैं. इससे स्थानीय व्यवहार का पता चलता है.
कॉनकरेंसी ट्री डायग्राम
नीचे दिए गए डायग्राम में, स्ट्रक्चर्ड कॉनमुद्रा का एक वैकल्पिक व्यू दिखाया गया है. यह ट्री स्ट्रक्चर को बेहतर तरीके से दिखाता है. ब्लॉक से एक छोटा पेड़ बनता है.
-
Skyframe में वैल्यू उपलब्ध न होने पर, शुरुआत से फिर से शुरू करने के बजाय, ↩
-
ध्यान दें कि
step
के पासInterruptedException
को फेंकने की अनुमति है, लेकिन उदाहरण में इसे छोड़ दिया गया है. Bazel कोड में कुछ ऐसे लो लेवल के तरीके हैं जो यह अपवाद दिखाते हैं. यह अपवादDriver
तक पहुंच जाता है. इसके बारे में बाद में बताया जाएगा. यहStateMachine
को चलाता है. ज़रूरत न होने पर, इसे फेंकने के लिए एलान न किया जा सकता है. ↩ -
एक साथ पूरे होने वाले सबटास्क,
ConfiguredTargetFunction
से प्रेरित थे. यह हर डिपेंडेंसी के लिए अलग काम करता है. एक साथ सभी डिपेंडेंसी को प्रोसेस करने वाले जटिल डेटा स्ट्रक्चर में बदलाव करने के बजाय, हर डिपेंडेंसी का अपना अलगStateMachine
होता है. ↩ -
एक ही चरण में होने वाले कई
tasks.lookUp
कॉल को बैच बनाकर भेजा जाता है. एक साथ किए जा रहे सबटास्क में होने वाले लुकअप की मदद से, अतिरिक्त बैच बनाए जा सकते हैं. ↩ -
यह कॉन्सेप्ट, Java के स्ट्रक्चर्ड कॉन्करेंसी jeps/428 से मिलता-जुलता है. ↩
-
ऐसा करना, क्रम से चलने वाले कंपोज़िशन पाने के लिए, थ्रेड को स्पैन करने और उसमें शामिल होने जैसा ही है. ↩