多线程过滤敏感词-白红宇

多线程过滤敏感词

阅读量：6068 次

发布时间：2019-06-20

本文共 2303 字，大约阅读时间需要 7 分钟。

原文：https://git.oschina.net/tianzhenjiu/codes/y9z6t471s3euinoj5vcdf79

package io.test;import java.util.ArrayList;import java.util.List;import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;public class Testoss {    public static void main(String[] args) throws Exception {                    String[] keywords={"毛","周","二逼","xx","王五","刘能","你好吗","共 产 党","哈哈","中国人"};                String content="你好哈222哈2哈啊大a我们是中国人在主实例的读请求较多、读压力比较大的时候，可以通过 DRDS 读写分离功能对读流量进行分流，减轻 RDS 主实例的读压力。你好哈222哈2哈啊大a我们是中国人在主实例的读请求较多、读压力比较大的时候，可以通过 DRDS 读写分离功能对读流量进行分流，减轻 RDS 主实例的读压力。你好哈222哈2哈啊大a我们是中国人在主实例的读请求较多、读压力比较大的时候，可以通过 DRDS 读写分离功能对读流量进行分流，减轻 RDS 主实例的读压力。你好哈222哈2哈啊大a我们是中国人在主实例的读请求较多、读压力比较大的时候，可以通过 DRDS 读写分离功能对读流量进行分流，减轻 RDS 主实例的读压力。你好哈222哈2哈啊大a我们是中国人在主实例的读请求较多、读压力比较大的时候，可以通过 DRDS 读写分离功能对读流量进行分流，减轻 RDS 主实例的读压力。你好哈222哈2哈啊大a我们是中国人在主实例的读请求较多、读压力比较大的时候，可以通过 DRDS 读写分离功能对读流量进行分流，减轻 RDS 主实例的读压力。";        int splitthread=2;                int count=keywords.length/splitthread;                ExecutorService executorService=Executors.newFixedThreadPool(4);                boolean filterit=false;                                List
     
      
       > futures=new ArrayList<>();        for(int i=0;i
       
         strings=new ArrayList<>();                        for(int j=0;i+j
        
         () {                @Override                public String call() throws Exception {                                    return filter(content, strings);                }                                            }));                                }                for(Future
         
           future:futures){                        if(future.get()!=null){                filterit=true;                System.out.println(future.get());            }        }                executorService.shutdown();                System.out.println(filterit);                    }        /**     *      * @param content  内容     * @param keywords 过滤词组     * @return     */    public static String filter(String content,List
          
            keywords){// // try {// Thread.sleep(1000);// } catch (InterruptedException e) {// e.printStackTrace();// }// for(String keyword:keywords){ if(content.indexOf(keyword)>0) return keyword; } return null; } }