init

Author: axetroy

.editorconfig

@@ -0,0 +1,11 @@
+root = true
+
+[*]
+indent_style = tab
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+indent_size = 4
+indent_style = space
+max_line_length = 140

.gitattributes

@@ -0,0 +1 @@
+* text=auto eol=lf

.github/FUNDING.yml

@@ -0,0 +1,12 @@
+# These are supported funding model platforms
+
+github: axetroy # Replace with up to 4 GitHub Sponsors-enabled usernames e.g., [user1, user2]
+patreon: # Replace with a single Patreon username
+open_collective: # Replace with a single Open Collective username
+ko_fi: # Replace with a single Ko-fi username
+tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
+community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
+liberapay: # Replace with a single Liberapay username
+issuehunt: # Replace with a single IssueHunt username
+otechie: # Replace with a single Otechie username
+custom: https://github.com/axetroy/buy-me-a-cup-of-tea

.github/workflows/build.yml

@@ -0,0 +1,29 @@
+name: build
+
+on: [push, pull_request]
+
+jobs:
+  build:
+    runs-on: ${{ matrix.os }}
+    strategy:
+      matrix:
+        node: ["22"]
+        os: [ubuntu-latest, macOS-latest]
+    name: node.js ${{ matrix.node }} test in ${{ matrix.os }}
+    steps:
+      - uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - uses: actions/setup-node@v3
+        with:
+          node-version: ${{ matrix.node }}
+
+      - name: Install
+        run: npm i
+
+      - name: Test
+        run: npm run test
+
+      - name: Build
+        run: npm run build

.gitignore

@@ -0,0 +1,4 @@
+node_modules
+package-lock.json
+dist
+.DS_Store

LICENSE

@@ -0,0 +1,46 @@
+Copyright (c) 2025 Axetroy
+
+"Anti 996" License Version 1.0 (Draft)
+
+Permission is hereby granted to any individual or legal entity
+obtaining a copy of this licensed work (including the source code,
+documentation and/or related items, hereinafter collectively referred
+to as the "licensed work"), free of charge, to deal with the licensed
+work for any purpose, including without limitation, the rights to use,
+reproduce, modify, prepare derivative works of, distribute, publish
+and sublicense the licensed work, subject to the following conditions:
+
+1. The individual or the legal entity must conspicuously display,
+without modification, this License and the notice on each redistributed
+or derivative copy of the Licensed Work.
+
+2. The individual or the legal entity must strictly comply with all
+applicable laws, regulations, rules and standards of the jurisdiction
+relating to labor and employment where the individual is physically
+located or where the individual was born or naturalized; or where the
+legal entity is registered or is operating (whichever is stricter). In
+case that the jurisdiction has no such laws, regulations, rules and
+standards or its laws, regulations, rules and standards are
+unenforceable, the individual or the legal entity are required to
+comply with Core International Labor Standards.
+
+3. The individual or the legal entity shall not induce, suggest or force
+its employee(s), whether full-time or part-time, or its independent
+contractor(s), in any methods, to agree in oral or written form, to
+directly or indirectly restrict, weaken or relinquish his or her
+rights or remedies under such laws, regulations, rules and standards
+relating to labor and employment as mentioned above, no matter whether
+such written or oral agreements are enforceable under the laws of the
+said jurisdiction, nor shall such individual or the legal entity
+limit, in any methods, the rights of its employee(s) or independent
+contractor(s) from reporting or complaining to the copyright holder or
+relevant authorities monitoring the compliance of the license about
+its violation(s) of the said license.
+
+THE LICENSED WORK IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
+IN NO EVENT SHALL THE COPYRIGHT HOLDER BE LIABLE FOR ANY CLAIM,
+DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+OTHERWISE, ARISING FROM, OUT OF OR IN ANY WAY CONNECTION WITH THE
+LICENSED WORK OR THE USE OR OTHER DEALINGS IN THE LICENSED WORK.

README.md

@@ -0,0 +1,45 @@
+# async-queue.js
+
+[![Badge](https://img.shields.io/badge/link-996.icu-%23FF4D5B.svg?style=flat-square)](https://996.icu/#/en_US)
+[![LICENSE](https://img.shields.io/badge/license-Anti%20996-blue.svg?style=flat-square)](https://github.com/996icu/996.ICU/blob/master/LICENSE)
+![Node](https://img.shields.io/badge/node-%3E=14-blue.svg?style=flat-square)
+[![npm version](https://badge.fury.io/js/@axetroy/async-queue.svg)](https://badge.fury.io/js/async-queue)
+
+A library to limit the number of concurrent asynchronous tasks.
+
+## Installation
+
+```bash
+npm install @axetroy/async-queue --save
+```
+
+## Usage
+
+```js
+// import via esm
+import { AsyncQueue } from "@axetroy/async-queue";
+
+// import via cjs
+const { AsyncQueue } = require("@axetroy/async-queue");
+```
+
+```js
+// import via esm
+import { AsyncQueue } from "@axetroy/async-queue";
+
+const delay = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
+
+const queue = new AsyncTaskQueue(2);
+// Add task to the queue
+queue.enqueue(() => delay(1000).then(() => console.log("Task 1 completed")));
+queue.enqueue(() => delay(500).then(() => console.log("Task 2 completed")));
+queue.enqueue(() => delay(300).then(() => console.log("Task 3 completed")));
+queue.enqueue(() => delay(400).then(() => console.log("Task 4 completed")));
+
+// Wait for all tasks to complete
+await queue.waitForAll();
+```
+
+## License
+
+The [Anti 996 License](LICENSE)

package.json

@@ -0,0 +1,56 @@
+{
+    "name": "async-queue",
+    "version": "0.1.0",
+    "private": false,
+    "description": "A simple async queue",
+    "sideEffects": false,
+    "files": [
+        "dist"
+    ],
+    "main": "./dist/cjs/index.cjs",
+    "module": "./dist/esm/index.mjs",
+    "exports": {
+        "./package.json": {
+            "import": "./package.json",
+            "require": "./package.json"
+        },
+        ".": {
+            "require": {
+                "default": "./dist/cjs/index.cjs",
+                "types": "./dist/cjs/index.d.ts"
+            },
+            "import": {
+                "default": "./dist/esm/index.mjs",
+                "types": "./dist/esm/index.d.ts"
+            }
+        }
+    },
+    "scripts": {
+        "test": "node --import tsx --test **/*.test.ts",
+        "test:update-snapshot": "node --import tsx --test --test-update-snapshots **/*.test.ts",
+        "build": "npm run build:esm && npm run build:cjs",
+        "build:esm": "tsc -p ./tsconfig.esm.json && node script/covert2mjs.cjs",
+        "build:cjs": "tsc -p ./tsconfig.cjs.json && node script/covert2cjs.cjs",
+        "prepack": "npm run build"
+    },
+    "author": "Axetroy <[email protected]>",
+    "license": "MIT",
+    "devDependencies": {
+        "@types/node": "^22.13.10",
+        "tsx": "^4.19.2",
+        "typescript": "^5.7.2"
+    },
+    "keywords": [
+        "queue",
+        "async",
+        "async-queue"
+    ],
+    "homepage": "https://github.com/axetroy/async-queue.js#readme",
+    "bugs": {
+        "url": "https://github.com/axetroy/async-queue.js/issues"
+    },
+    "repository": {
+        "type": "https",
+        "url": "https://github.com/axetroy/async-queue.js.git"
+    }
+}

script/covert2cjs.cjs

@@ -0,0 +1,6 @@
+const path = require("path");
+
+// 定义要处理的文件夹路径
+const dirPath = path.join(__dirname, "../dist/cjs"); // 根据实际情况设置
+
+require("./renameModule.cjs")(dirPath, "cjs");

script/covert2mjs.cjs

@@ -0,0 +1,6 @@
+const path = require("path");
+
+// 定义要处理的文件夹路径
+const dirPath = path.join(__dirname, "../dist/esm"); // 根据实际情况设置
+
+require("./renameModule.cjs")(dirPath, "mjs");