Supplier<Integer> nonThreadSafe =
        new Supplier<Integer>() {
          int counter = 0;

          @Override
          public Integer get() {
            int nextValue = counter + 1;
            Thread.yield();
            counter = nextValue;
            return counter;
          }
        };

    int numThreads = 10;
    int iterations = 1000;
    Thread[] threads = new Thread[numThreads];

  }

  private static void insertIntoReplica(Map<Integer, AtomicInteger> replica, int newValue) {
    if (replica.containsKey(newValue)) {
      replica.get(newValue).incrementAndGet();
    } else {
      replica.put(newValue, new AtomicInteger(1));
    }
  }

  private static void removeMinFromReplica(
      SortedMap<Integer, AtomicInteger> replica, int minValue) {

                var newValue = this.startDate.format(this.locale.format);
                if (!this.singleDatePicker) {
                    newValue += this.locale.separator + this.endDate.format(this.locale.format);
                }
                if (newValue !== this.element.val()) {
                    this.element.val(newValue).trigger('change');
                }
            }

				if isReservedOrInvalidBucket(volInfo.Name, false) {
					continue
				}

				healBuckets.Compute(volInfo.Name, func(oldValue VolInfo, loaded bool) (newValue VolInfo, del bool) {
					if loaded {
						newValue = oldValue
						newValue.count = oldValue.count + 1
						return newValue, false
					}
					return VolInfo{
						Name:    volInfo.Name,
						Created: volInfo.Created,
						count:   1,
					}, false
				})

        assertEquals(true, builder.initialSettings.get("key3"));

        // Test overwriting existing setting
        builder.addInitialSettings("key1", "newValue1");
        assertEquals(3, builder.initialSettings.size());
        assertEquals("newValue1", builder.initialSettings.get("key1"));
    }

    @Test
    public void testAddInitialSettingsWithNullValue() {
        // Test adding null value

        assertEquals("value3", crawlingInfoHelper.infoMap.get("key3"));

        // Test overwriting existing key
        crawlingInfoHelper.putToInfoMap("key1", "new_value1");
        assertEquals("new_value1", crawlingInfoHelper.infoMap.get("key1"));
    }

    public void test_store_create() {
        final String sessionId = "test-session-123";

        // Mock CrawlingInfoService

        // Test overwriting existing keys
        paramMap = new HashMap<>();
        paramMap.put("key1", "oldValue");
        configParam = "key1=newValue";
        ParameterUtil.loadConfigParams(paramMap, configParam);
        assertEquals(1, paramMap.size());
        assertEquals("newValue", paramMap.get("key1"));
    }

    public void test_createConfigParameterMap() {
        String configParameters;

     * Concatenates values to a destination list, avoiding duplicates.
     * @param dest The destination list.
     * @param newValues The new values to add.
     * @param <T> The type of the values.
     */
    protected static <T> void concatValues(final List<T> dest, final T... newValues) {
        for (final T value : newValues) {
            if (!dest.contains(value)) {
                dest.add(value);
            }
        }
    }

 * </ul>
 *
 * <p>Usage:
 * <pre>
 * DynamicProperties dynamicProperties = new DynamicProperties("path/to/properties/file");
 * String value = dynamicProperties.getProperty("key");
 * dynamicProperties.setProperty("key", "newValue");
 * dynamicProperties.store();
 * </pre>
 *
 * <p>Exceptions:
 * <ul>
 *   <li>{@link FileAccessException} - Thrown if there are issues accessing the file.</li>

高度なシナリオでは、「キャッシュされた」値を使うのではなく、同じリクエストの各ステップ（おそらく複数回）で依存関係を呼び出す必要があることがわかっている場合、`Depens`を使用する際に、`use_cache=False`というパラメータを設定することができます。

```Python hl_lines="1"
async def needy_dependency(fresh_value: str = Depends(get_value, use_cache=False)):
    return {"fresh_value": fresh_value}
```

## まとめ

ここで使われている派手な言葉は別にして、**依存性注入** システムは非常にシンプルです。

*path operation関数*と同じように見えるただの関数です。