<commit_before>package kutil

import (
	"time"
)

type KEvent struct {
	ch chan int
}

func (k *KEvent) init() {
	if k.ch == nil {
		k.ch = make(chan int, 1)
	}
}

/*0：表示超时返回，> 0表示事件返回。
 */
func (k *KEvent) Wait(t int64) int {

	k.init()

	for {
		select {
		case <-time.After(time.Duration(t)):
			return 0
		case v := <-k.ch:
			return v
		}
	}
}

/*确保v值必须大于0
 */
func (k *KEvent) Post(v int) {
	k.init()
	if v <= 0 {
		v = 1
	}
	k.ch <- v
}

func (k *KEvent) Close() {
	if k.ch != nil {
		close(k.ch)
	}
}
<commit_msg>取消管道的长度限制。<commit_after>package kutil

import (
	"time"
)

type KEvent struct {
	ch chan int
}

func (k *KEvent) init() {
	if k.ch == nil {
		k.ch = make(chan int)
	}
}

/*0：表示超时返回，> 0表示事件返回。
 */
func (k *KEvent) Wait(t int64) int {

	k.init()

	for {
		select {
		case <-time.After(time.Duration(t)):
			return 0
		case v := <-k.ch:
			return v
		}
	}
}

/*确保v值必须大于0
 */
func (k *KEvent) Post(v int) {
	k.init()
	if v <= 0 {
		v = 1
	}
	k.ch <- v
}

func (k *KEvent) Close() {
	if k.ch != nil {
		close(k.ch)
	}
}

{'fraction_non_alphanumeric': 0.19305019305019305, 'fraction_numerical': 0.016409266409266408, 'mean_word_length': 2.366883116883117, 'pattern_counts': {'":': 0, '<': 11, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1133741', 'n_tokens_mistral': 575, 'n_tokens_neox': 537, 'n_words': 125}